MCPcopy Index your code
hub / github.com/ReactiveX/RxJava / subscribeWith

Method subscribeWith

src/main/java/io/reactivex/rxjava3/core/Maybe.java:5445–5451  ·  view source on GitHub ↗

Subscribes a given MaybeObserver (subclass) to this Maybe and returns the given MaybeObserver as is. Usage example: Maybe<Integer> source = Maybe.just(1); CompositeDisposable composite = new CompositeDisposable(); DisposableMaybeObserver<Integer> d

(E observer)

Source from the content-addressed store, hash-verified

5443 * @throws NullPointerException if {@code observer} is {@code null}
5444 */
5445 @CheckReturnValue
5446 @SchedulerSupport(SchedulerSupport.NONE)
5447 @NonNull
5448 public final <@NonNull E extends MaybeObserver<? super T>> E subscribeWith(E observer) {
5449 subscribe(observer);
5450 return observer;
5451 }
5452
5453 /**
5454 * Returns a {@code Maybe} that emits the items emitted by the current {@code Maybe} or the items of an alternate

Callers 15

toFutureMethod · 0.95
subscribeMethod · 0.95
toCompletionStageMethod · 0.95
flatMapMethod · 0.45
flatMapCompletableMethod · 0.45
subscribeOnFlowableMethod · 0.45
observeOnFlowableMethod · 0.45
pipelineFlowableMethod · 0.45
subscribeOnObservableMethod · 0.45
observeOnObservableMethod · 0.45
pipelineObservableMethod · 0.45
observeOnSingleMethod · 0.45

Calls 1

subscribeMethod · 0.95

Tested by

no test coverage detected