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)
| 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 |