akarnokd / Rxjavainterop
Licence: apache-2.0
Library to convert between RxJava 1.x and 2.x/3.x reactive types, schedulers and resource handles.
Stars: ✭ 856
Programming Languages
java
68154 projects - #9 most used programming language
Projects that are alternatives of or similar to Rxjavainterop
Rxjavajdk8interop
RxJava 2/3 interop library for supporting Java 8 features such as Optional, Stream and CompletableFuture [discontinued]
Stars: ✭ 70 (-91.82%)
Mutual labels: rxjava, reactive-streams, extensions
Rxjavaextensions
RxJava 2.x & 3.x extra sources, operators and components and ports of many 1.x companion libraries.
Stars: ✭ 662 (-22.66%)
Mutual labels: rxjava, reactive-streams, extensions
Spring Reactive Sample
Spring 5 Reactive playground
Stars: ✭ 867 (+1.29%)
Mutual labels: rxjava, reactive-streams
Rxjava2 Extras
Utilities for use with RxJava 2
Stars: ✭ 167 (-80.49%)
Mutual labels: rxjava, reactive-streams
Autodispose
Automatic binding+disposal of RxJava streams.
Stars: ✭ 3,209 (+274.88%)
Mutual labels: rxjava, reactive-streams
Rxjava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
Stars: ✭ 45,607 (+5227.92%)
Mutual labels: rxjava, reactive-streams
Rxjavareactivestreams
Adapter between RxJava and ReactiveStreams
Stars: ✭ 227 (-73.48%)
Mutual labels: rxjava, reactive-streams
reactor-go
A golang implementation for reactive-streams.
Stars: ✭ 48 (-94.39%)
Mutual labels: rxjava, reactive-streams
rxjava2-http
Transmit RxJava2 Flowable over http with non-blocking backpressure
Stars: ✭ 19 (-97.78%)
Mutual labels: rxjava, reactive-streams
Rxjava2 Jdbc
RxJava2 integration with JDBC including Non-blocking Connection Pools
Stars: ✭ 360 (-57.94%)
Mutual labels: rxjava, reactive-streams
Hivemq Mqtt Client
HiveMQ MQTT Client is an MQTT 5.0 and MQTT 3.1.1 compatible and feature-rich high-performance Java client library with different API flavours and backpressure support
Stars: ✭ 402 (-53.04%)
Mutual labels: rxjava, reactive-streams
Fcfrtmvp
🔥FcfrtMvp+RxHttp+RxJava(Kotlin和JAVA共用完美支持)支持一键创建MVP项目,框架简约风格及详细注释,欢迎 star or fork!
Stars: ✭ 23 (-97.31%)
Mutual labels: rxjava
Mvvmhabit
goldze: 本人喜欢尝试新的技术,以后发现有好用的东西,我将会在企业项目中实战,没有问题了就会把它引入到MVVMHabit中,一直维护着这套框架,谢谢各位朋友的支持。如果觉得这套框架不错的话,麻烦点个 star,你的支持则是我前进的动力!
Stars: ✭ 6,789 (+693.11%)
Mutual labels: rxjava
Supermvp
MVP“美”图+新闻+天气预报+Material+RxJava3+Retrofit2+Glide4+AndroidX+Leakcanary+Butterknife
Stars: ✭ 763 (-10.86%)
Mutual labels: rxjava
Reactive Serial
Reactive Streams API for Serial Communication
Stars: ✭ 24 (-97.2%)
Mutual labels: reactive-streams
Cep Resources
Tools and documentation for building Creative Cloud app extensions with CEP
Stars: ✭ 916 (+7.01%)
Mutual labels: extensions
Easygank
💊 The project build framework based on the Rx series and MVP pattern.
Stars: ✭ 750 (-12.38%)
Mutual labels: rxjava
Rxcombine
Bi-directional type bridging between RxSwift and Apple's Combine framework
Stars: ✭ 741 (-13.43%)
Mutual labels: reactive-streams
RxJavaInterop
Library to convert between RxJava 1.x and 3.x reactive types.
Interop between 2.x and 3.x
Check out the https://github.com/akarnokd/RxJavaBridge project.
Releases
gradle
dependencies {
implementation "com.github.akarnokd:rxjava3-interop:3.0.2"
}
Maven search:
Usage
Convert between the reactive base types
import hu.akarnokd.rxjava3.interop.RxJavaInterop;
// convert from 1.x to 3.x
io.reactivex.rxjava3.core.Flowable f3 = RxJavaInterop.toV3Flowable(rx.Observable);
io.reactivex.rxjava3.core.Observable o3 = RxJavaInterop.toV3Observable(rx.Observable);
io.reactivex.rxjava3.core.Single s3 = RxJavaInterop.toV3Single(rx.Single);
io.reactivex.rxjava3.core.Completable c3 = RxJavaInterop.toV3Completable(rx.Completable);
io.reactivex.rxjava3.core.Maybe m3s = RxJavaInterop.toV3Maybe(rx.Single);
io.reactivex.rxjava3.core.Maybe m3c = RxJavaInterop.toV3Maybe(rx.Completable);
// convert from 3.x to 1.x
rx.Observable o1 = RxJavaInterop.toV1Observable(Publisher);
rx.Observable q1 = RxJavaInterop.toV1Observable(ObservableSource, BackpressureStrategy);
rx.Single s1 = RxJavaInterop.toV1Single(SingleSource);
rx.Completable c1 = RxJavaInterop.toV1Completable(CompletableSource);
rx.Single s1m = RxJavaInterop.toV1Single(MaybeSource);
rx.Completable c1m = RxJavaInterop.toV1Completable(MaybeSource);
Convert between Subjects and Processors.
Note that 3.x Subject
s and FlowableProcessor
s support only the same input and output types.
// convert from 1.x to 3.x
io.reactivex.rxjava3.subjects.Subject sj3 = RxJavaInterop.toV3Subject(rx.subjects.Subject);
io.reactivex.rxjava3.processors.FlowableProcessor fp3 = RxJavaInterop.toV3Processor(rx.subjects.Subject);
// convert from 3.x to 1.x
rx.subjects.Subject sj1 = RxJavaInterop.toV1Subject(io.reactivex.rxjava3.subjects.Subject);
rx.subjects.Subject sj1b = RxJavaInterop.toV1Subject(io.reactivex.rxjava3.processors.FlowableProcessor);
X.Transformer
s and 3.x XTransformer
s.
Convert between 1.x // convert from 1.x to 3.x
io.reactivex.rxjava3.core.FlowableTransformer ft3 = RxJavaInterop.toV3Transformer(
rx.Observable.Transformer);
io.reactivex.rxjava3.core.ObservableTransformer ot3 = RxJavaInterop.toV3Transformer(
rx.Observable.Transformer,
io.reactivex.rxjava3.core.BackpressureStrategy);
io.reactivex.rxjava3.core.SingleTransformer st3 = RxJavaInterop.toV3Transformer(
rx.Single.Transformer);
io.reactivex.rxjava3.core.CompletableTransformer ct3 = RxJavaInterop.toV3Transformer(
rx.Completable.Transformer);
// convert from 3.x to 1.x
rx.Observable.Transformer ft1 = RxJavaInterop.toV1Transformer(
io.reactivex.rxjava3.core.FlowableTransformer);
rx.Observable.Transformer ot1 = RxJavaInterop.toV1Transformer(
io.reactivex.rxjava3.core.ObservableTransformer,
io.reactivex.rxjava3.core.BackpressureStrategy);
rx.Single.Transformer st1 = RxJavaInterop.toV1Transformer(
io.reactivex.rxjava3.core.SingleTransformer);
rx.Completable.Transformer ct1 = RxJavaInterop.toV1Transformer(
io.reactivex.rxjava3.core.CompletableTransformer);
Flowable.Operator
and 3.x FlowableOperator
Convert between 1.x // convert from 1.x to 3.x
io.reactivex.rxjava3.core.FlowableOperator fo3 = RxJavaInterop.toV3Operator(rx.Observable.Operator);
// convert from 3.x to 1.x
rx.Observable.Operator fo1 = RxJavaInterop.toV1Operator(io.reactivex.rxjava3.core.FlowableOperator);
Subscription
and 3.x Disposable
Convert between 1.x // convert from 1.x to 3.x
io.reactivex.rxjava3.disposables.Disposable d3 = RxJavaInterop.toV3Disposable(rx.Subscription);
// convert from 3.x to 1.x
rx.Subscription s1 = RxJavaInterop.toV1Subscription(io.reactivex.rxjava3.disposables.Disposable);
Scheduler
s and 3.x Scheduler
s
Convert between 1.x // convert from 1.x to 3.x
io.reactivex.rxjava3.core.Scheduler s3 = RxJavaInterop.toV3Scheduler(rx.Scheduler);
// convert from 3.x to 1.x
rx.Scheduler s1 = RxJavaInterop.toV1Scheduler(io.reactivex.rxjava3.core.Scheduler);
Note that the project description data, including the texts, logos, images, and/or trademarks,
for each open source project belongs to its rightful owner.
If you wish to add or remove any projects, please contact us at [email protected].