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 89b8f03d88..2db32733db 100644 --- a/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt +++ b/node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt @@ -280,7 +280,7 @@ class ObservablesTests { } }) source.subscribe { heartBeat += it } - // wrap FlowSafeSubject with a FlowSafeSubscriber + // wrapping FlowSafeSubject with a SafeSubscriber val sourceWrapper = SafeSubscriber(Subscribers.from(source)) assertFailsWith { sourceWrapper.onNext(1)