diff --git a/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt b/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt index 6319fe77d7..2666e40245 100644 --- a/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt +++ b/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt @@ -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`() {