Kyriakos Tharrouniatis 2c9c2985c0 CORDA-3381: Errors in vault updates publisher are unsubscribing stopping observers from working (#5912) ... * Throw SQLException or PersistenceException plain, that may come out of an unsafe subscriber * Add explanatory comment about why we changed Observer.tee to use unsafe subscribe * Introducing not unsubscribing version of Rx.Subscriber * Wrap PublishSubjects with FlowSafeSubjects in all tests that test Observer.tee * Minor code formatting * Make rawUpdates Rx.Observers not unsubscribe when accessed from CordaServices - Do not allow rawUpdates subscribing from flows * Warning fix: Add else block to when statement * Revert "Wrap PublishSubjects with FlowSafeSubjects in all tests that test Observer.tee" This reverts commit e419af86 * Correcting log message * Improve log message * Add fiber's id to log message and exception message * Added test, asserting FlowSafeSubscriber is alive and re-accessed upon flow retry * Logging flow name instead of flow id at VaultService.rawUpdates subscribing error * Add kdoc to OnNextFailedException * Minor text correction * Update kdocs of FlowSafeSubject/ PreventSubscriptionsSubject * Moved FlowSafeSubject under package node.internal as it is only used by NodeVaultService * Add comment and update kdoc explaining how to subscribe with SafeSubscriber to FlowSafeSubject * Change PreventSubscriptionsSubject#errorAction to be more specific; to return an Exception * Minor text update * Update messy comment * Replace assertThat with assertEquals * Splitting heartBeat to heartBeat1 and hearBeat2 for more clear asserting * Correcting comment * Update messy comment * Splitting heartBeat into heartBeatOnNext and heartBeatOnError * Update test name * Add explanatory comment to test * Update test name * Update test and add test comment * Moving NotarisedTxs from SendStateFlow to VaultObserverExceptionTest inside NodeHandle.getNotarisedTransactionIds * Moving SubscribingRawUpdatesFlow from ErrorHandling to VaultObserverExceptionTest * Update kdoc of FlowSafeSubscriber and FlowSafeSubscriber.onNext * Make kdoc more clear * Throw exception upon accessing VaultService.rawUpdates from within a flow * Changing exception thrown when accessing VaultService.rawUpdates from within a flow to a CordaRuntimeException * Minor kdoc update * Update test comment * Update kdoc of FlowSafeSubscriber * Introducing Observable.flowSafeSubscribe public API method to subscribe with -non unsubscribing- Rx.Subscribers to Observables. It also replaced FlowSafeSubject * Move CustomSafeSubscriber outside test methods * Minor text update * Add timeout to tests * Update kdoc of flowSafeSubscribe * Update kdoc of flowSafeSubscribe * Update kdoc of flowSafeSubscribe * Move FlowSafeSubscriber and flowSafeSubscribe under their own package * Fix detekt issue * Update Detekt baseline * Revert "Update Detekt baseline" This reverts commit 793a8ed9 * Fix Detekt issue * Moved strictMode flag from flowSafeSubscribe to OnFlowSafeSubscribe Moved OnFlowSafeSubscribe into internal package Integration tested flowSafeLooseSubscribe * Suppress Rx Deprecation * Rename flowSafeSubscribe to flowSafeObservable * Renaming flowSafeObservable to continueOnError and FlowSafeSubscriber to ResilientSubscriber		2020-02-21 10:02:34 +00:00
..
dbfcontracts	CORDA-3381: Errors in vault updates publisher are unsubscribing stopping observers from working (#5912)	2020-02-21 10:02:34 +00:00
dbfworkflows	CORDA-3381: Errors in vault updates publisher are unsubscribing stopping observers from working (#5912)	2020-02-21 10:02:34 +00:00