From 5f939661ecfce685b84fbf378b7005aa03709ec7 Mon Sep 17 00:00:00 2001 From: Kyriakos Tharrouniatis Date: Tue, 18 Feb 2020 14:24:20 +0000 Subject: [PATCH] Update kdoc of flowSafeSubscribe --- .../main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt b/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt index 4a8c05bffe..8e4d641f23 100644 --- a/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt +++ b/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt @@ -95,7 +95,7 @@ class OnNextFailedException(message: String, cause: Throwable) : OnErrorNotImple * 1. Declare a custom SafeSubscriber extending [SafeSubscriber]. * 2. Wrap with the custom SafeSubscriber the [rx.Observer] to be subscribed to the source [Observable]. * 3. Call [Observable.flowSafeSubscribe] with [strictMode] = false - * 4. Subscribe passing in as argument the custom SafeSubscriber. + * 4. Subscribe to the returned [Observable] passing in as argument the custom SafeSubscriber. */ fun Observable.flowSafeSubscribe(strictMode: Boolean = false): Observable {