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

Method subscribe

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

Subscribes to a Maybe and ignores onSuccess and onComplete emissions. If the Maybe emits an error, it is wrapped into an io.reactivex.rxjava3.exceptions.OnErrorNotImplementedException OnErrorNotImplementedException and routed to the {@link RxJavaPlugins#on

()

Source from the content-addressed store, hash-verified

5231 * @see #subscribe(Consumer, Consumer, Action, DisposableContainer)
5232 */
5233 @SchedulerSupport(SchedulerSupport.NONE)
5234 @NonNull
5235 public final Disposable subscribe() {
5236 return subscribe(Functions.emptyConsumer(), Functions.ON_ERROR_MISSING, Functions.EMPTY_ACTION);
5237 }
5238
5239 /**
5240 * Subscribes to a {@code Maybe} and provides a callback to handle the items it emits.

Callers 5

blockingGetMethod · 0.95
blockingSubscribeMethod · 0.95
safeSubscribeMethod · 0.95
subscribeWithMethod · 0.95
testMethod · 0.95

Calls 7

emptyConsumerMethod · 0.95
subscribeWithMethod · 0.95
onSubscribeMethod · 0.95
subscribeActualMethod · 0.95
throwIfFatalMethod · 0.95
initCauseMethod · 0.80
addMethod · 0.65

Tested by

no test coverage detected