Difference between revisions of "RxJava"

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 14:56, 2 March 2020