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

Method create

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

Provides an API (via a cold Maybe) that bridges the reactive world with the callback-style world. Example: Maybe.<Event>create(emitter ->

(@NonNull MaybeOnSubscribe<T> onSubscribe)

Source from the content-addressed store, hash-verified

864 * @see Cancellable
865 */
866 @CheckReturnValue
867 @NonNull
868 @SchedulerSupport(SchedulerSupport.NONE)
869 public static <@NonNull T> Maybe<T> create(@NonNull MaybeOnSubscribe<T> onSubscribe) {
870 Objects.requireNonNull(onSubscribe, "onSubscribe is null");
871 return RxJavaPlugins.onAssembly(new MaybeCreate<>(onSubscribe));
872 }
873
874 /**
875 * Calls a {@link Supplier} for each individual {@link MaybeObserver} to return the actual {@link MaybeSource} source to

Callers 15

basicMethod · 0.95
basicWithCancellableMethod · 0.95
basicWithErrorMethod · 0.95
basicWithCompletionMethod · 0.95
basicMethod · 0.95
basicWithErrorMethod · 0.95
basicWithCompleteMethod · 0.95
callbackThrowsMethod · 0.95
onSuccessNullMethod · 0.95
onErrorNullMethod · 0.95
disposeMethod · 0.95
onSuccessThrowsMethod · 0.95

Calls 1

onAssemblyMethod · 0.95

Tested by 15

basicMethod · 0.76
basicWithCancellableMethod · 0.76
basicWithErrorMethod · 0.76
basicWithCompletionMethod · 0.76
basicMethod · 0.76
basicWithErrorMethod · 0.76
basicWithCompleteMethod · 0.76
callbackThrowsMethod · 0.76
onSuccessNullMethod · 0.76
onErrorNullMethod · 0.76
disposeMethod · 0.76
onSuccessThrowsMethod · 0.76