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

Method concat

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

Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by an Iterable sequence as a Flowable sequence.

(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends T>> sources)

Source from the content-addressed store, hash-verified

184 * @throws NullPointerException if {@code sources} is {@code null}
185 */
186 @BackpressureSupport(BackpressureKind.FULL)
187 @CheckReturnValue
188 @NonNull
189 @SchedulerSupport(SchedulerSupport.NONE)
190 public static <@NonNull T> Flowable<T> concat(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends T>> sources) {
191 Objects.requireNonNull(sources, "sources is null");
192 return RxJavaPlugins.onAssembly(new MaybeConcatIterable<>(sources));
193 }
194
195 /**
196 * Returns a {@link Flowable} that emits the items emitted by two {@link MaybeSource}s, one after the other.

Callers 15

concat2Method · 0.95
concat2EmptyMethod · 0.95
concat2BackpressuredMethod · 0.95
concat3Method · 0.95
concat3EmptyMethod · 0.95
concat3Mixed1Method · 0.95
concat3Mixed2Method · 0.95
concat3BackpressuredMethod · 0.95
concat4Method · 0.95
concatIterableMethod · 0.95
concatIterableEmptyMethod · 0.95

Calls 4

onAssemblyMethod · 0.95
concatArrayMethod · 0.95
verifyPositiveMethod · 0.95
identityMethod · 0.95

Tested by 15

concat2Method · 0.76
concat2EmptyMethod · 0.76
concat2BackpressuredMethod · 0.76
concat3Method · 0.76
concat3EmptyMethod · 0.76
concat3Mixed1Method · 0.76
concat3Mixed2Method · 0.76
concat3BackpressuredMethod · 0.76
concat4Method · 0.76
concatIterableMethod · 0.76
concatIterableEmptyMethod · 0.76