Skip to content

Commit 17b325e

Browse files
authored
2.x: Apply missing RxJavaPlugins.onAssembly on ops (#4877)
1 parent e5ae0b9 commit 17b325e

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

src/main/java/io/reactivex/Maybe.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2606,7 +2606,7 @@ public final <U, R> Maybe<R> flatMap(Function<? super T, ? extends MaybeSource<?
26062606
@BackpressureSupport(BackpressureKind.FULL)
26072607
@SchedulerSupport(SchedulerSupport.NONE)
26082608
public final <U> Flowable<U> flattenAsFlowable(final Function<? super T, ? extends Iterable<? extends U>> mapper) {
2609-
return new MaybeFlatMapIterableFlowable<T, U>(this, mapper);
2609+
return RxJavaPlugins.onAssembly(new MaybeFlatMapIterableFlowable<T, U>(this, mapper));
26102610
}
26112611

26122612
/**
@@ -2628,7 +2628,7 @@ public final <U> Flowable<U> flattenAsFlowable(final Function<? super T, ? exten
26282628
*/
26292629
@SchedulerSupport(SchedulerSupport.NONE)
26302630
public final <U> Observable<U> flattenAsObservable(final Function<? super T, ? extends Iterable<? extends U>> mapper) {
2631-
return new MaybeFlatMapIterableObservable<T, U>(this, mapper);
2631+
return RxJavaPlugins.onAssembly(new MaybeFlatMapIterableObservable<T, U>(this, mapper));
26322632
}
26332633

26342634
/**

src/main/java/io/reactivex/Observable.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6347,7 +6347,7 @@ public final <K> Observable<T> distinct(Function<? super T, K> keySelector) {
63476347
public final <K> Observable<T> distinct(Function<? super T, K> keySelector, Callable<? extends Collection<? super K>> collectionSupplier) {
63486348
ObjectHelper.requireNonNull(keySelector, "keySelector is null");
63496349
ObjectHelper.requireNonNull(collectionSupplier, "collectionSupplier is null");
6350-
return new ObservableDistinct<T, K>(this, keySelector, collectionSupplier);
6350+
return RxJavaPlugins.onAssembly(new ObservableDistinct<T, K>(this, keySelector, collectionSupplier));
63516351
}
63526352

63536353
/**
@@ -8387,7 +8387,7 @@ public final ConnectableObservable<T> publish() {
83878387
@SchedulerSupport(SchedulerSupport.NONE)
83888388
public final <R> Observable<R> publish(Function<? super Observable<T>, ? extends ObservableSource<R>> selector) {
83898389
ObjectHelper.requireNonNull(selector, "selector is null");
8390-
return new ObservablePublishSelector<T, R>(this, selector);
8390+
return RxJavaPlugins.onAssembly(new ObservablePublishSelector<T, R>(this, selector));
83918391
}
83928392

83938393
/**

src/main/java/io/reactivex/Single.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1958,7 +1958,7 @@ public final <R> Flowable<R> flatMapPublisher(Function<? super T, ? extends Publ
19581958
@BackpressureSupport(BackpressureKind.FULL)
19591959
@SchedulerSupport(SchedulerSupport.NONE)
19601960
public final <U> Flowable<U> flattenAsFlowable(final Function<? super T, ? extends Iterable<? extends U>> mapper) {
1961-
return new SingleFlatMapIterableFlowable<T, U>(this, mapper);
1961+
return RxJavaPlugins.onAssembly(new SingleFlatMapIterableFlowable<T, U>(this, mapper));
19621962
}
19631963

19641964
/**
@@ -1980,7 +1980,7 @@ public final <U> Flowable<U> flattenAsFlowable(final Function<? super T, ? exten
19801980
*/
19811981
@SchedulerSupport(SchedulerSupport.NONE)
19821982
public final <U> Observable<U> flattenAsObservable(final Function<? super T, ? extends Iterable<? extends U>> mapper) {
1983-
return new SingleFlatMapIterableObservable<T, U>(this, mapper);
1983+
return RxJavaPlugins.onAssembly(new SingleFlatMapIterableObservable<T, U>(this, mapper));
19841984
}
19851985

19861986
/**

0 commit comments

Comments
 (0)