ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-04-16 15:29:34 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Make kdoc more clear

Browse Source
This commit is contained in:
Kyriakos Tharrouniatis 2020-02-17 13:06:30 +00:00
parent 071d58cbf7
commit 3000d58022
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node/src/main/kotlin/net/corda/node/internal/FlowSafeSubject.kt
View File

@ -9,8 +9,8 @@ import rx.subjects.Subject
/**
* [FlowSafeSubject] is used to unwrap an [Observer] from a [SafeSubscriber], re-wrap it with a [FlowSafeSubscriber]
* and then subscribe it to its underlying [Subject]. It is only used to provide therefore, its underlying [Subject] with
* non unsubscribing [rx.Observer]s.
* and then subscribe it to its underlying [Subject]. It is only used therefore, to provide its underlying [Subject] with
* subscribing of non unsubscribing [rx.Observer]s.
*
* Upon [rx.Observable.subscribe] it will wrap everything that is a non [SafeSubscriber] with a [FlowSafeSubscriber] the same way
* [rx.subjects.PublishSubject] wraps everything that is a non [SafeSubscriber] with a [SafeSubscriber].