June 2018
Intermediate to advanced
310 pages
6h 32m
English
It's important not to call the onNext()/onComplete()/onError() methods from different threads, as it will make the calls non-serializable.
This is a Proxy of sorts around any regular subject, which synchronizes calls to the unsafe methods. You can wrap any subject with SerializedSubject using the toSerialized() method:
val subject = ReplaySubject.createWithSize<Int>(2).toSerialized()
Read now
Unlock full access