ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-03-18 01:55:19 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Update test comment

Browse Source
This commit is contained in:
Kyriakos Tharrouniatis 2020-02-17 14:03:55 +00:00
parent bececa153d
commit 82f6e9b3db
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt
View File

@ -290,10 +290,11 @@ class ObservablesTests {
}
/**
* A FlowSafeSubscriber that is NOT a leaf in a Subscribers structure, if it throws at onNext, it will not call its onError.
* A [FlowSafeSubscriber] that is NOT a leaf in a subscribers structure will not call [onError]
* if an error occurs during its [onNext] event processing.
*
* The reason why it should not call its onError is: if it wraps a [PublishSubject], calling [FlowSafeSubscriber.onError]
* will then call [PublishSubject.onError] which will shut down all the Subscribers under the [PublishSubject].
* The reason why it should not call its onError is: if it wraps a [PublishSubject], calling [FlowSafeSubscriber.onError]
* will then call [PublishSubject.onError] which will shut down all the subscribers under the [PublishSubject].
*/
@Test
fun `FlowSafeSubject wrapped with a FlowSafeSubscriber will preserve the structure, if one of them is unsafe and it throws`() {