You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
<div class="block">Await the completion of the current stage.</div>
521
521
</dd>
522
-
<dt><a href="io/reactivex/rxjava4/core/Streamer.html#await(java.util.concurrent.CompletionStage)" class="member-name-link">await(CompletionStage)</a> - Static method in interface io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Streamer.html" title="interface in io.reactivex.rxjava4.core">Streamer</a></dt>
523
-
<dd>
524
-
<div class="block">The <code>await</code> keyword for async/await.</div>
525
-
</dd>
526
-
<dt><a href="io/reactivex/rxjava4/core/Streamer.html#await(java.util.concurrent.CompletionStage,io.reactivex.rxjava4.disposables.DisposableContainer)" class="member-name-link">await(CompletionStage, DisposableContainer)</a> - Static method in interface io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Streamer.html" title="interface in io.reactivex.rxjava4.core">Streamer</a></dt>
527
-
<dd>
528
-
<div class="block">The cancellable <code>await</code> keyword for async/await.</div>
529
-
</dd>
530
522
<dt><a href="io/reactivex/rxjava4/observers/BaseTestConsumer.html#awaitCount(int)" class="member-name-link">awaitCount(int)</a> - Method in class io.reactivex.rxjava4.observers.<a href="io/reactivex/rxjava4/observers/BaseTestConsumer.html" title="class in io.reactivex.rxjava4.observers">BaseTestConsumer</a></dt>
531
523
<dd>
532
524
<div class="block">Await until the <code>TestObserver</code>/<code>TestSubscriber</code> receives the given
<div class="block">Returns a <a href="io/reactivex/rxjava4/core/Flowable.html" title="class in io.reactivex.rxjava4.core"><code>Flowable</code></a> that emits the items emitted by four <a href="io/reactivex/rxjava4/core/SingleSource.html" title="interface in io.reactivex.rxjava4.core"><code>SingleSource</code></a>s, one after the other.</div>
1653
1645
</dd>
1646
+
<dt><a href="io/reactivex/rxjava4/core/Streamable.html#concat(io.reactivex.rxjava4.core.Streamable,java.util.concurrent.ExecutorService)" class="member-name-link">concat(Streamable, ExecutorService)</a> - Static method in interface io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Streamable.html" title="interface in io.reactivex.rxjava4.core">Streamable</a></dt>
1647
+
<dd>
1648
+
<div class="block">Emits the elements of each inner sequence produced by the outher sequence.</div>
1649
+
</dd>
1654
1650
<dt><a href="io/reactivex/rxjava4/core/Completable.html#concat(java.lang.Iterable)" class="member-name-link">concat(Iterable)</a> - Static method in class io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Completable.html" title="class in io.reactivex.rxjava4.core">Completable</a></dt>
1655
1651
<dd>
1656
1652
<div class="block">Returns a <code>Completable</code> which completes only when all sources complete, one after another.</div>
<a href="io/reactivex/rxjava4/core/Notification.html" title="class in io.reactivex.rxjava4.core"><code>Notification</code></a> objects extracted from the source items via a selector function
3194
3190
into their respective <a href="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="interface in java.util.concurrent" class="external-link"><code>Flow.Subscriber</code></a> signal types.</div>
3195
3191
</dd>
3192
+
<dt><a href="io/reactivex/rxjava4/disposables/CompositeDisposable.html#derive()" class="member-name-link">derive()</a> - Method in class io.reactivex.rxjava4.disposables.<a href="io/reactivex/rxjava4/disposables/CompositeDisposable.html" title="class in io.reactivex.rxjava4.disposables">CompositeDisposable</a></dt>
3193
+
<dd> </dd>
3194
+
<dt><a href="io/reactivex/rxjava4/disposables/DisposableContainer.html#derive()" class="member-name-link">derive()</a> - Method in interface io.reactivex.rxjava4.disposables.<a href="io/reactivex/rxjava4/disposables/DisposableContainer.html" title="interface in io.reactivex.rxjava4.disposables">DisposableContainer</a></dt>
3195
+
<dd>
3196
+
<div class="block">Create a derived sub container that can get cancelled by this container,
3197
+
but cancelling the subcontainer does not cancel this container.</div>
3198
+
</dd>
3199
+
<dt><a href="io/reactivex/rxjava4/disposables/DisposableContainer.NeverDisposableContainer.html#derive()" class="member-name-link">derive()</a> - Method in record class io.reactivex.rxjava4.disposables.<a href="io/reactivex/rxjava4/disposables/DisposableContainer.NeverDisposableContainer.html" title="class in io.reactivex.rxjava4.disposables">DisposableContainer.NeverDisposableContainer</a></dt>
3200
+
<dd> </dd>
3196
3201
<dt><a href="io/reactivex/rxjava4/core/CompletionStageDisposable.html#disposable()" class="member-name-link">disposable()</a> - Method in class io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/CompletionStageDisposable.html" title="class in io.reactivex.rxjava4.core">CompletionStageDisposable</a></dt>
3197
3202
<dd>
3198
3203
<div class="block">Returns the associated disposable value.</div>
<div class="block">Returns an <code>Observable</code> instance that when subscribed to, subscribes to the <a href="io/reactivex/rxjava4/core/SingleSource.html" title="interface in io.reactivex.rxjava4.core"><code>SingleSource</code></a> instance and
4808
4813
emits <code>onSuccess</code> as a single item or forwards the <code>onError</code> signal.</div>
4809
4814
</dd>
4815
+
<dt><a href="io/reactivex/rxjava4/core/Streamable.html#fromStages(java.lang.Iterable,java.util.concurrent.ExecutorService)" class="member-name-link">fromStages(Iterable, ExecutorService)</a> - Static method in interface io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Streamable.html" title="interface in io.reactivex.rxjava4.core">Streamable</a></dt>
4816
+
<dd>
4817
+
<div class="block">Generates a sequence in order which the stages complete in any form.</div>
4818
+
</dd>
4810
4819
<dt><a href="io/reactivex/rxjava4/core/Flowable.html#fromStream(java.util.stream.Stream)" class="member-name-link">fromStream(Stream)</a> - Static method in class io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Flowable.html" title="class in io.reactivex.rxjava4.core">Flowable</a></dt>
4811
4820
<dd>
4812
4821
<div class="block">Converts a <a href="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/util/stream/Stream.html" title="interface in java.util.stream" class="external-link"><code>Stream</code></a> into a finite <code>Flowable</code> and emits its items in the sequence.</div>
<div class="block">Specifies where each 'rail' will observe its incoming values, specified via a <a href="io/reactivex/rxjava4/core/Scheduler.html" title="class in io.reactivex.rxjava4.core"><code>Scheduler</code></a>, with
8553
8562
possibly work-stealing and a given prefetch amount.</div>
8554
8563
</dd>
8555
-
<dt><a href="io/reactivex/rxjava4/core/Streamer.html#runStage(java.util.function.Function,io.reactivex.rxjava4.disposables.DisposableContainer)" class="member-name-link">runStage(Function, DisposableContainer)</a> - Static method in interface io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Streamer.html" title="interface in io.reactivex.rxjava4.core">Streamer</a></dt>
8556
-
<dd>
8557
-
<div class="block">Runs a function while turning it into a CompletionStage with a canceller supplied too.</div>
8558
-
</dd>
8559
-
<dt><a href="io/reactivex/rxjava4/core/Streamer.html#runStage(java.util.function.Function,io.reactivex.rxjava4.disposables.DisposableContainer,java.util.concurrent.Executor)" class="member-name-link">runStage(Function, DisposableContainer, Executor)</a> - Static method in interface io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/Streamer.html" title="interface in io.reactivex.rxjava4.core">Streamer</a></dt>
8560
-
<dd>
8561
-
<div class="block">Runs a function while turning it into a CompletionStage with a canceller supplied too.</div>
8562
-
</dd>
8563
8564
<dt><a href="io/reactivex/rxjava4/plugins/RxJavaPlugins.html" class="type-name-link" title="class in io.reactivex.rxjava4.plugins">RxJavaPlugins</a> - Class in <a href="io/reactivex/rxjava4/plugins/package-summary.html">io.reactivex.rxjava4.plugins</a></dt>
8564
8565
<dd>
8565
8566
<div class="block">Utility class to inject handlers to certain standard RxJava operations.</div>
0 commit comments