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
<dd>The operator expects the upstream to support backpressure and honors
@@ -16986,6 +16986,8 @@ <h4>flatMapMaybe</h4>
16986
16986
public final <R> <a href="../../../../io/reactivex/rxjava3/annotations/NonNull.html" title="annotation in io.reactivex.rxjava3.annotations">@NonNull</a> <a href="../../../../io/reactivex/rxjava3/core/Flowable.html" title="class in io.reactivex.rxjava3.core">Flowable</a><R> flatMapMaybe(<a href="../../../../io/reactivex/rxjava3/annotations/NonNull.html" title="annotation in io.reactivex.rxjava3.annotations">@NonNull</a> <a href="../../../../io/reactivex/rxjava3/functions/Function.html" title="interface in io.reactivex.rxjava3.functions">Function</a><? super <a href="../../../../io/reactivex/rxjava3/core/Flowable.html" title="type parameter in Flowable">T</a>,? extends <a href="../../../../io/reactivex/rxjava3/core/MaybeSource.html" title="interface in io.reactivex.rxjava3.core">MaybeSource</a><? extends R>> mapper)</pre>
16987
16987
<div class="block">Maps each element of the upstream <code>Flowable</code> into <a href="../../../../io/reactivex/rxjava3/core/MaybeSource.html" title="interface in io.reactivex.rxjava3.core"><code>MaybeSource</code></a>s, subscribes to all of them
16988
16988
and merges their <code>onSuccess</code> values, in no particular order, into a single <code>Flowable</code> sequence.
<dd>The operator consumes the upstream in an unbounded manner.</dd>
@@ -17020,6 +17022,8 @@ <h4>flatMapMaybe</h4>
17020
17022
<div class="block">Maps each element of the upstream <code>Flowable</code> into <a href="../../../../io/reactivex/rxjava3/core/MaybeSource.html" title="interface in io.reactivex.rxjava3.core"><code>MaybeSource</code></a>s, subscribes to at most
17021
17023
<code>maxConcurrency</code> <code>MaybeSource</code>s at a time and merges their <code>onSuccess</code> values,
17022
17024
in no particular order, into a single <code>Flowable</code> sequence, optionally delaying all errors.
<dd>If <code>maxConcurrency == </code><a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true#MAX_VALUE" title="class or interface in java.lang"><code>Integer.MAX_VALUE</code></a> the operator consumes the upstream in an unbounded manner.
<dd><code>concatMapMaybe</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
@@ -12592,7 +12592,7 @@ <h4>concatMapMaybe</h4>
12592
12592
other succeeds or completes, emits their success value if available or terminates immediately if
12593
12593
either the current <code>Observable</code> or the current inner <code>MaybeSource</code> fail.
<dd><code>concatMapMaybe</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
<dd><code>concatMapMaybeDelayError</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
<dd><code>concatMapMaybeDelayError</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
<dd><code>concatMapMaybeDelayError</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
@@ -12768,7 +12768,7 @@ <h4>concatMapSingle</h4>
12768
12768
other succeeds, emits their success values or terminates immediately if
12769
12769
either the current <code>Observable</code> or the current inner <code>SingleSource</code> fail.
<dd><code>concatMapSingle</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
@@ -12808,7 +12808,7 @@ <h4>concatMapSingle</h4>
12808
12808
other succeeds, emits their success values or terminates immediately if
12809
12809
either the current <code>Observable</code> or the current inner <code>SingleSource</code> fail.
<dd><code>concatMapSingle</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
<dd><code>concatMapSingleDelayError</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
<dd><code>concatMapSingleDelayError</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
<dd><code>concatMapSingleDelayError</code> does not operate by default on a particular <a href="../../../../io/reactivex/rxjava3/core/Scheduler.html" title="class in io.reactivex.rxjava3.core"><code>Scheduler</code></a>.</dd>
0 commit comments