ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-07 11:30:22 +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:14:25 +00:00
parent 2459530a14
commit 79577a110a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -93,9 +93,9 @@ class OnNextFailedException(message: String, cause: Throwable) : OnErrorNotImple
*
* In case we need to subscribe with a [SafeSubscriber] via [flowSafeSubscribe], we have to:
* 1. Call it with [strictMode] = false
* 1. Declare a custom Subscriber that will extend [SafeSubscriber].
* 2. Wrap with the custom Subscriber the [rx.Observer] to be subscribed to [FlowSafeSubject].
* 3. Subscribe to [FlowSafeSubject] passing the custom Subscriber.
* 1. Declare a custom SafeSubscriber extending [SafeSubscriber].
* 2. Wrap with the custom SafeSubscriber the [rx.Observer] to be subscribed to the source [Observable].
* 3. Subscribe passing in as argument the custom SafeSubscriber.
*/
fun <T> Observable<T>.flowSafeSubscribe(strictMode: Boolean = false): Observable<T> {