mirror of
https://github.com/corda/corda.git
synced 2025-02-25 19:11:45 +00:00
Correcting comment
This commit is contained in:
parent
11d92f90d5
commit
4f3fc81081
@ -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<OnErrorFailedException> {
|
||||
sourceWrapper.onNext(1)
|
||||
|
Loading…
x
Reference in New Issue
Block a user