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

Update kdoc of flowSafeSubscribe

Browse Source
This commit is contained in:
Kyriakos Tharrouniatis 2020-02-18 14:24:20 +00:00
parent d5facae178
commit 5f939661ec
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt
View File

@ -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 <T> Observable<T>.flowSafeSubscribe(strictMode: Boolean = false): Observable<T> {