RxJava: Difference between revisions

From BITPlan Wiki
Jump to navigation Jump to search
Line 16: Line 16:
<uml>
<uml>
hide circle  
hide circle  
package org {
  package reactivestreams {
note top of Subscriber
Will receive call to onSubscribe(Subscription)
once after passing an instance of
Subscriber to Publisher.subscribe(Subscriber).
No further notifications will be received
until Subscription.request(long) is called.
see [[https://www.reactive-streams.org/reactive-streams-1.0.0-javadoc/org/reactivestreams/Subscriber.html javadoc]]
end note
    interface Subscriber {
        void onComplete()
        void onError(java.lang.Throwable t)
        void onNext(T t)
        void onSubscribe(Subscription s)
    }
  }
}
package io {
package io {
   package reactivex {
   package reactivex {

Revision as of 12:56, 2 March 2020