@@ -35,17 +35,17 @@ import hu.akarnokd.rxjava3.interop.RxJavaInterop;
3535
3636// convert from 1.x to 3.x
3737
38- io.reactivex. Flowable f2 = RxJavaInterop . toV3Flowable(rx. Observable );
38+ io.reactivex.rxjava3.core . Flowable f3 = RxJavaInterop . toV3Flowable(rx. Observable );
3939
40- io.reactivex. Observable o2 = RxJavaInterop . toV3Observable(rx. Observable );
40+ io.reactivex.rxjava3.core . Observable o3 = RxJavaInterop . toV3Observable(rx. Observable );
4141
42- io.reactive . Single s2 = RxJavaInterop . toV3Single(rx. Single );
42+ io.reactivex.rxjava3.core . Single s3 = RxJavaInterop . toV3Single(rx. Single );
4343
44- io.reactivex. Completable c2 = RxJavaInterop . toV3Completable(rx. Completable );
44+ io.reactivex.rxjava3.core . Completable c3 = RxJavaInterop . toV3Completable(rx. Completable );
4545
46- io.reactivex. Maybe m2s = RxJavaInterop . toV3Maybe(rx. Single );
46+ io.reactivex.rxjava3.core . Maybe m3s = RxJavaInterop . toV3Maybe(rx. Single );
4747
48- io.reactivex. Maybe m2c = RxJavaInterop . toV3Maybe(rx. Completable );
48+ io.reactivex.rxjava3.core . Maybe m3c = RxJavaInterop . toV3Maybe(rx. Completable );
4949
5050// convert from 3.x to 1.x
5151
@@ -69,65 +69,67 @@ Note that 3.x `Subject`s and `FlowableProcessor`s support only the same input an
6969``` java
7070// convert from 1.x to 3.x
7171
72- io.reactivex.subjects. Subject sj2 = RxJavaInterop . toV3Subject(rx.subjects. Subject );
72+ io.reactivex.rxjava3. subjects. Subject sj3 = RxJavaInterop . toV3Subject(rx.subjects. Subject );
7373
74- io.reactivex.processors. FlowableProcessor fp2 = RxJavaInterop . toV3Processor(rx.subjects. Subject );
74+ io.reactivex.rxjava3. processors. FlowableProcessor fp3 = RxJavaInterop . toV3Processor(rx.subjects. Subject );
7575
7676// convert from 3.x to 1.x
7777
78- rx.subjects. Subject sj1 = RxJavaInterop . toV1Subject(io.reactivex.subjects. Subject );
78+ rx.subjects. Subject sj1 = RxJavaInterop . toV1Subject(io.reactivex.rxjava3. subjects. Subject );
7979
80- rx.subjects. Subject sj1b = RxJavaInterop . toV1Subject(io.reactivex.processors. FlowableProcessor );
80+ rx.subjects. Subject sj1b = RxJavaInterop . toV1Subject(io.reactivex.rxjava3. processors. FlowableProcessor );
8181```
8282
8383### Convert between 1.x ` X.Transformer ` s and 3.x ` XTransformer ` s.
8484
8585``` java
8686// convert from 1.x to 3.x
8787
88- io.reactivex. FlowableTransformer ft2 = RxJavaInterop . toV3Transformer(rx. Observable . Transformer );
88+ io.reactivex.rxjava3.core . FlowableTransformer ft2 = RxJavaInterop . toV3Transformer(rx. Observable . Transformer );
8989
90- io.reactivex. ObservableTransformer ot2 = RxJavaInterop . toV3Transformer(
91- rx. Observable . Transformer , io.reactivex. BackpressureStrategy );
90+ io.reactivex.rxjava3.core. ObservableTransformer ot2 = RxJavaInterop . toV3Transformer(
91+ rx. Observable . Transformer ,
92+ io.reactivex.rxjava3.core. BackpressureStrategy );
9293
93- io.reactivex. SingleTransformer st2 = RxJavaInterop . toV3Transformer(rx. Single . Transformer );
94+ io.reactivex.rxjava3.core . SingleTransformer st2 = RxJavaInterop . toV3Transformer(rx. Single . Transformer );
9495
95- io.reactivex. CompletableTransformer ct2 = RxJavaInterop . toV3Transformer(rx. Completable . Transformer );
96+ io.reactivex.rxjava3.core . CompletableTransformer ct2 = RxJavaInterop . toV3Transformer(rx. Completable . Transformer );
9697
9798// convert from 3.x to 1.x
9899
99- rx. Observable . Transformer ft1 = RxJavaInterop . toV1Transformer(io.reactivex. FlowableTransformer );
100+ rx. Observable . Transformer ft1 = RxJavaInterop . toV1Transformer(io.reactivex.rxjava3.core . FlowableTransformer );
100101
101102rx. Observable . Transformer ot1 = RxJavaInterop . toV1Transformer(
102- io.reactivex. ObservableTransformer , io.reactivex. BackpressureStrategy );
103+ io.reactivex.rxjava3.core. ObservableTransformer ,
104+ io.reactivex.rxjava3.core. BackpressureStrategy );
103105
104- rx. Single . Transformer st1 = RxJavaInterop . toV1Transformer(io.reactivex. SingleTransformer );
106+ rx. Single . Transformer st1 = RxJavaInterop . toV1Transformer(io.reactivex.rxjava3.core . SingleTransformer );
105107
106- rx. Completable . Transformer ct1 = RxJavaInterop . toV1Transformer(io.reactivex. CompletableTransformer );
108+ rx. Completable . Transformer ct1 = RxJavaInterop . toV1Transformer(io.reactivex.rxjava3.core . CompletableTransformer );
107109```
108110
109111### Convert between 1.x ` Flowable.Operator ` and 3.x ` FlowableOperator `
110112
111113``` java
112114// convert from 1.x to 3.x
113115
114- io.reactivex. FlowableOperator fo2 = RxJavaInterop . toV3Operator(rx. Observable . Operator );
116+ io.reactivex.rxjava3.core . FlowableOperator fo2 = RxJavaInterop . toV3Operator(rx. Observable . Operator );
115117
116118// convert from 3.x to 1.x
117119
118- rx. Observable . Operator fo1 = RxJavaInterop . toV1Operator(io.reactivex. FlowableOperator );
120+ rx. Observable . Operator fo1 = RxJavaInterop . toV1Operator(io.reactivex.rxjava3.core . FlowableOperator );
119121```
120122
121123### Convert between 1.x ` Subscription ` and 3.x ` Disposable `
122124
123125``` java
124126// convert from 1.x to 3.x
125127
126- io.reactivex.disposables. Disposable d2 = RxJavaInterop . toV3Disposable(rx. Subscription );
128+ io.reactivex.rxjava3. disposables. Disposable d2 = RxJavaInterop . toV3Disposable(rx. Subscription );
127129
128130// convert from 3.x to 1.x
129131
130- rx. Subscription s1 = RxJavaInterop . toV1Subscription(io.reactivex.disposables. Disposable );
132+ rx. Subscription s1 = RxJavaInterop . toV1Subscription(io.reactivex.rxjava3. disposables. Disposable );
131133```
132134
133135
@@ -136,9 +138,9 @@ rx.Subscription s1 = RxJavaInterop.toV1Subscription(io.reactivex.disposables.Dis
136138``` java
137139// convert from 1.x to 3.x
138140
139- io.reactivex. Scheduler s2 = RxJavaInterop . toV3Scheduler(rx. Scheduler );
141+ io.reactivex.rxjava3.core . Scheduler s2 = RxJavaInterop . toV3Scheduler(rx. Scheduler );
140142
141143// convert from 3.x to 1.x
142144
143- rx. Scheduler s1 = RxJavaInterop . toV1Scheduler(io.reactivex. Scheduler );
145+ rx. Scheduler s1 = RxJavaInterop . toV1Scheduler(io.reactivex.rxjava3.core . Scheduler );
144146```
0 commit comments