RxJava: Difference between revisions

From BITPlan Wiki
Jump to navigation Jump to search
 
(14 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
     note top of Observer
Provides a mechanism for receiving  
Provides a mechanism for receiving  
Line 48: 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  
  note top of Observer  
Provides a mechanism  
Provides a mechanism  
Line 57: 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 74: 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 15: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"