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

Update messy comment

Browse Source
This commit is contained in:
Kyriakos Tharrouniatis 2020-02-17 00:32:44 +00:00
parent 4f3fc81081
commit f024c7db9e
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,9 +290,10 @@ class ObservablesTests {
}
/**
* A FlowSafeSubscriber that is not a leaf in a Subscribers structure, if it throws at onNext,
* it will not call its onError, because in case it wraps a [PublishSubject] it will then call [PublishSubject.onError]
* which will shut down all of the Subscribers under it.
* A FlowSafeSubscriber that is NOT a leaf in a Subscribers structure, if it throws at onNext, it will not call its onError.
*
* 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`() {