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

Method just

src/main/java/io/reactivex/rxjava3/core/Flowable.java:3032–3039  ·  view source on GitHub ↗

Returns a Flowable that signals the given (constant reference) item and then completes. Note that the item is taken and re-emitted as is and not computed by any me

(T item)

Source from the content-addressed store, hash-verified

3030 * @see #fromIterable(Iterable)
3031 */
3032 @CheckReturnValue
3033 @NonNull
3034 @BackpressureSupport(BackpressureKind.FULL)
3035 @SchedulerSupport(SchedulerSupport.NONE)
3036 public static <@NonNull T> Flowable<T> just(T item) {
3037 Objects.requireNonNull(item, "item is null");
3038 return RxJavaPlugins.onAssembly(new FlowableJust<>(item));
3039 }
3040
3041 /**
3042 * Converts two items into a {@link Publisher} that emits those items.

Callers 15

applyMethod · 0.95
applyMethod · 0.95
applyMethod · 0.95
merge1SyncStreamOfNMethod · 0.95
setupMethod · 0.95
applyMethod · 0.95
setupMethod · 0.95
applyMethod · 0.95
setupMethod · 0.95
applyMethod · 0.95
applyMethod · 0.95
applyMethod · 0.95

Calls 2

onAssemblyMethod · 0.95
fromArrayMethod · 0.95