Difference between revisions of "RxJava"

From BITPlan Wiki
Jump to navigation Jump to search
 
(25 intermediate revisions by the same user not shown)
Line 8: Line 8:
 
* https://mvnrepository.com/artifact/io.reactivex.rxjava3/rxjava
 
* https://mvnrepository.com/artifact/io.reactivex.rxjava3/rxjava
 
* https://github.com/ReactiveX/RxJava/wiki/What's-different-in-3.0
 
* https://github.com/ReactiveX/RxJava/wiki/What's-different-in-3.0
 +
<uml>
 +
hide circle
 +
package io {
 +
  package reactivex {
 +
    package rjxjava3 {
 +
      package core {
 +
        note top of Observer
 +
see [[http://reactivex.io/RxJava/3.x/javadoc/io/reactivex/rxjava3/core/Observer.html javadoc]]
 +
        end note
 +
        interface Observer {
 +
          void onComplete()
 +
          void onError(@NonNull Throwable e)
 +
          void onNext(T t)
 +
          void onSubscribe(@NonNull Disposable d)
 +
        }
 +
      }
 +
    }
 +
  }
 +
}
 +
</uml>
  
 
== RxJava 2 ==
 
== RxJava 2 ==
Line 14: Line 34:
 
* https://github.com/ReactiveX/RxJava/wiki/What%27s-different-in-2.0
 
* https://github.com/ReactiveX/RxJava/wiki/What%27s-different-in-2.0
 
* https://blog.kaush.co/2017/06/21/rxjava1-rxjava2-migration-understanding-changes/
 
* https://blog.kaush.co/2017/06/21/rxjava1-rxjava2-migration-understanding-changes/
 +
* https://howtoprogram.xyz/2017/02/07/how-to-create-observable-in-rxjava-2/
 
<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)
 +
    }
 +
note top of Subscription
 +
A Subscription represents a
 +
one-to-one lifecycle of a Subscriber
 +
subscribing to a Publisher.
 +
 +
It can only be used once by a single Subscriber.
 +
 +
It is used to both signal desire for data
 +
and cancel demand (and allow resource cleanup).
 +
see [[https://www.reactive-streams.org/reactive-streams-1.0.0-javadoc/org/reactivestreams/Subscription.html javadoc]]
 +
end note
 +
    interface Subscription {
 +
        void cancel()
 +
        void request(long n)
 +
    }
 +
  }
 +
}
 
package io {
 
package io {
 
   package reactivex {
 
   package reactivex {
 +
    note top of Observable
 +
The Observable class is the non-backpressured,
 +
optionally multi-valued base reactive class that
 +
offers factory methods, intermediate operators and
 +
the ability to consume synchronous
 +
and/or asynchronous reactive dataflows.
 +
see [[http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Observable.html javadoc]].
 +
end note
 +
    class Observable {
 +
      Disposable subscribe(Consumer<? super T> onNext)
 +
    }
 +
    note top of Observer
 +
Provides a mechanism for receiving
 +
push-based notifications see [[http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Observer.html javadoc]].
 +
end note
 
     interface Observer {
 
     interface Observer {
 
       void onComplete()
 
       void onComplete()
Line 25: Line 95:
 
   }
 
   }
 
   package disposables {
 
   package disposables {
 +
    note top of Disposable
 +
Represents a disposable resource
 +
see[[http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/disposables/Disposable.html javadoc]].
 +
end note
 
     interface Disposable {
 
     interface Disposable {
 
         void dispose()
 
         void dispose()
Line 40: Line 114:
 
hide circle  
 
hide circle  
 
package rx {
 
package rx {
 +
note top of Observable
 +
The Observable class that
 +
implements the Reactive Pattern.
 +
see [[http://reactivex.io/RxJava/javadoc/rx/Observable.html javadoc]]
 +
end note
 +
interface Observable {
 +
  Subscription subscribe()
 +
}
 +
note top of Observer
 +
Provides a mechanism
 +
for receiving push-based notifications see [[http://reactivex.io/RxJava/javadoc/rx/Observer.html  javadoc]]
 +
end note
 
   interface Observer {
 
   interface Observer {
 
     void onCompleted()
 
     void onCompleted()
Line 45: Line 131:
 
     void onNext(T t)
 
     void onNext(T t)
 
   }
 
   }
 +
note top of Subscriber
 +
Provides a mechanism
 +
for receiving push-based notifications
 +
from Observables, and permits manual
 +
unsubscribing from these Observables
 +
see [[http://reactivex.io/RxJava/javadoc/rx/Subscriber.html javadoc]].
 +
end note
 +
  interface Subscriber {
 +
    void add(Subscription s)
 +
    boolean isUnsubscribed()
 +
    void onStart()
 +
    protected void request(long n)
 +
    void setProducer(Producer p)
 +
    void unsubscribe()
 +
  }
 +
  note top of Subscription
 +
Subscription returns from
 +
Observable.subscribe(Subscriber)
 +
to allow unsubscribing
 +
see [[http://reactivex.io/RxJava/javadoc/rx/Observer.html javadoc]].
 +
end note
 
   interface Subscription {
 
   interface Subscription {
 
     boolean isUnsubscribed()
 
     boolean isUnsubscribed()
Line 62: Line 169:
 
* https://www.littlerobots.nl/blog/Note-to-self-RxJava-SyncOnSubscribe/
 
* https://www.littlerobots.nl/blog/Note-to-self-RxJava-SyncOnSubscribe/
 
* https://pedroo21.github.io/RxJava/
 
* https://pedroo21.github.io/RxJava/
 +
* https://github.com/Froussios/Intro-To-RxJava/blob/master/Part%203%20-%20Taming%20the%20sequence/6.%20Hot%20and%20Cold%20observables.md
 +
* https://proandroiddev.com/understanding-rxjava-subscribeon-and-observeon-744b0c6a41ea
 +
 
= WhatLinksHere =
 
= WhatLinksHere =
 
{{WhatLinksHere}}
 
{{WhatLinksHere}}

Latest revision as of 16:29, 2 March 2020

Click here to comment see Self Driving RC Car

github

Versions

RxJava 3

3.0.0 was released 2020-02-14

RxJava 2

2.0.0 was released 2016-11-29 there will be bugfixes until 2021-02-28

RxJava 1

1.0.0 was released 2014-11

Links

WhatLinksHere

Retrieved from "https://wiki.bitplan.com/index.php?title=RxJava&oldid=11882"