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

Method concat

src/main/java/io/reactivex/rxjava3/core/Single.java:192–198  ·  view source on GitHub ↗

Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by an Iterable sequence. Backpressure: </

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

Source from the content-addressed store, hash-verified

190 * @since 2.0
191 */
192 @CheckReturnValue
193 @NonNull
194 @SchedulerSupport(SchedulerSupport.NONE)
195 @BackpressureSupport(BackpressureKind.FULL)
196 public static <@NonNull T> Flowable<T> concat(@NonNull Iterable<@NonNull ? extends SingleSource<? extends T>> sources) {
197 return Flowable.fromIterable(sources).concatMapSingleDelayError(Functions.identity(), false);
198 }
199
200 /**
201 * Concatenate the single values, in a non-overlapping fashion, of the {@link SingleSource}s provided by

Callers 10

scalarMethod · 0.95
callableMethod · 0.95
concat2Method · 0.95
concat3Method · 0.95
concat4Method · 0.95
concatObservableMethod · 0.95
concatWithMethod · 0.95

Calls 6

fromIterableMethod · 0.95
identityMethod · 0.95
onAssemblyMethod · 0.95
verifyPositiveMethod · 0.95
fromArrayMethod · 0.95

Tested by 9

scalarMethod · 0.76
callableMethod · 0.76
concat2Method · 0.76
concat3Method · 0.76
concat4Method · 0.76
concatObservableMethod · 0.76