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
<divclass="block">Abstract base implementation of a
213
-
<detailsclass="invalid-tag">
214
-
<summary>invalid reference</summary>
215
-
<pre><code>Subscriber</code></pre>
216
-
</details>
217
-
with
212
+
<divclass="block">Abstract base implementation of a <ahref="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="class or interface in java.util.concurrent" class="external-link"><code>Subscriber</code></a> with
218
213
support for requesting via <ahref="io/reactivex/rxjava4/subscribers/DefaultSubscriber.html#request(long)"><code>DefaultSubscriber.request(long)</code></a>, cancelling via
219
214
via <ahref="io/reactivex/rxjava4/subscribers/DefaultSubscriber.html#cancel()"><code>DefaultSubscriber.cancel()</code></a> (both synchronously) and calls <ahref="io/reactivex/rxjava4/subscribers/DefaultSubscriber.html#onStart()"><code>DefaultSubscriber.onStart()</code></a>
220
215
when the subscription happens.</div>
@@ -283,12 +278,7 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
283
278
</div>
284
279
<divclass="col-first even-row-color all-classes-table all-classes-table-tab1"><ahref="io/reactivex/rxjava4/core/FlowableEmitter.html" title="interface in io.reactivex.rxjava4.core">FlowableEmitter<T></a></div>
<divclass="block">Abstraction over a Reactive Streams <ahref="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="class or interface in java.util.concurrent" class="external-link"><code>Flow.Subscriber</code></a> that allows associating
292
282
a resource with it and exposes the current number of downstream
293
283
requested amount.</div>
294
284
</div>
@@ -533,11 +523,7 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
533
523
<divclass="col-first odd-row-color all-classes-table all-classes-table-tab5"><ahref="io/reactivex/rxjava4/exceptions/QueueOverflowException.html" title="class in io.reactivex.rxjava4.exceptions">QueueOverflowException</a></div>
<ahref="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html#onNext(T)" title="class or interface in java.util.concurrent" class="external-link"><code>Flow.Subscriber.onNext(Object)</code></a> was called concurrently from multiple threads
541
527
without synchronization.</div>
542
528
</div>
543
529
<divclass="col-first even-row-color all-classes-table all-classes-table-tab1"><ahref="io/reactivex/rxjava4/operators/QueueSubscription.html" title="interface in io.reactivex.rxjava4.operators">QueueSubscription<T></a></div>
<divclass="block">Default implementations for <ahref="io/reactivex/rxjava4/disposables/Disposable.html" title="interface in io.reactivex.rxjava4.disposables"><code>Disposable</code></a>-based resource management
<divclass="block">Classes representing so-called hot backpressure-aware sources, aka <strong>processors</strong>,
129
134
that implement the <ahref="io/reactivex/rxjava4/processors/FlowableProcessor.html" title="class in io.reactivex.rxjava4.processors"><code>FlowableProcessor</code></a> class,
130
-
the Reactive Streams
131
-
<detailsclass="invalid-tag">
132
-
<summary>invalid reference</summary>
133
-
<pre><code>Processor</code></pre>
134
-
</details>
135
-
interface
135
+
the Reactive Streams <ahref="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Processor.html" title="class or interface in java.util.concurrent" class="external-link"><code>Processor</code></a> interface
136
136
to allow forms of multicasting events to one or more subscribers as well as consuming another
137
-
Reactive Streams
138
-
<detailsclass="invalid-tag">
139
-
<summary>invalid reference</summary>
140
-
<pre><code>Publisher</code></pre>
141
-
</details>
142
-
.</div>
137
+
Reactive Streams <ahref="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Publisher.html" title="class or interface in java.util.concurrent" class="external-link"><code>Publisher</code></a>.</div>
<divclass="block">Default wrappers and implementations for
160
-
<detailsclass="invalid-tag">
161
-
<summary>invalid reference</summary>
162
-
<pre><code>Subscriber</code></pre>
163
-
</details>
164
-
-based consumer classes and interfaces,
154
+
<divclass="block">Default wrappers and implementations for <ahref="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="class or interface in java.util.concurrent" class="external-link"><code>Subscriber</code></a>-based consumer classes and interfaces,
165
155
including disposable (<ahref="io/reactivex/rxjava4/subscribers/DisposableSubscriber.html" title="class in io.reactivex.rxjava4.subscribers"><code>DisposableSubscriber</code></a>) and resource-tracking
166
156
(<ahref="io/reactivex/rxjava4/subscribers/ResourceSubscriber.html" title="class in io.reactivex.rxjava4.subscribers"><code>ResourceSubscriber</code></a>)
167
157
variants and the <ahref="io/reactivex/rxjava4/subscribers/TestSubscriber.html" title="class in io.reactivex.rxjava4.subscribers"><code>TestSubscriber</code></a> that allows unit testing
<dt><a href="io/reactivex/rxjava4/observers/BaseTestConsumer.html#assertEmpty()" class="member-name-link">assertEmpty()</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>
356
356
<dd>
357
357
<div class="block">Assert that the <code>TestObserver</code>/<code>TestSubscriber</code> has received a
358
-
<a href="io/reactivex/rxjava4/disposables/Disposable.html" title="interface in io.reactivex.rxjava4.disposables"><code>Disposable</code></a>/
359
-
<details class="invalid-tag">
360
-
<summary>invalid reference</summary>
361
-
<pre><code>Subscription</code></pre>
362
-
</details>
363
-
358
+
<a href="io/reactivex/rxjava4/disposables/Disposable.html" title="interface in io.reactivex.rxjava4.disposables"><code>Disposable</code></a>/<a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscription.html" title="class or interface in java.util.concurrent" class="external-link"><code>Subscription</code></a>
364
359
via <code>onSubscribe</code> but no other events.</div>
365
360
</dd>
366
361
<dt><a href="io/reactivex/rxjava4/observers/BaseTestConsumer.html#assertError(io.reactivex.rxjava4.functions.Predicate)" class="member-name-link">assertError(Predicate)</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>
<dt><a href="io/reactivex/rxjava4/subscribers/DefaultSubscriber.html" class="type-name-link" title="class in io.reactivex.rxjava4.subscribers">DefaultSubscriber<T></a> - Class in <a href="io/reactivex/rxjava4/subscribers/package-summary.html">io.reactivex.rxjava4.subscribers</a></dt>
2812
2807
<dd>
2813
-
<div class="block">Abstract base implementation of a
2814
-
<details class="invalid-tag">
2815
-
<summary>invalid reference</summary>
2816
-
<pre><code>Subscriber</code></pre>
2817
-
</details>
2818
-
with
2808
+
<div class="block">Abstract base implementation of a <a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="class or interface in java.util.concurrent" class="external-link"><code>Subscriber</code></a> with
2819
2809
support for requesting via <a href="io/reactivex/rxjava4/subscribers/DefaultSubscriber.html#request(long)"><code>DefaultSubscriber.request(long)</code></a>, cancelling via
2820
2810
via <a href="io/reactivex/rxjava4/subscribers/DefaultSubscriber.html#cancel()"><code>DefaultSubscriber.cancel()</code></a> (both synchronously) and calls <a href="io/reactivex/rxjava4/subscribers/DefaultSubscriber.html#onStart()"><code>DefaultSubscriber.onStart()</code></a>
<div class="block">Abstraction over a Reactive Streams <a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="class or interface in java.util.concurrent" class="external-link"><code>Flow.Subscriber</code></a> that allows associating
4248
4233
a resource with it and exposes the current number of downstream
<div class="block">Classes representing so-called hot backpressure-aware sources, aka <strong>processors</strong>,
5479
5469
that implement the <a href="io/reactivex/rxjava4/processors/FlowableProcessor.html" title="class in io.reactivex.rxjava4.processors"><code>FlowableProcessor</code></a> class,
5480
-
the Reactive Streams
5481
-
<details class="invalid-tag">
5482
-
<summary>invalid reference</summary>
5483
-
<pre><code>Processor</code></pre>
5484
-
</details>
5485
-
interface
5470
+
the Reactive Streams <a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Processor.html" title="class or interface in java.util.concurrent" class="external-link"><code>Processor</code></a> interface
5486
5471
to allow forms of multicasting events to one or more subscribers as well as consuming another
5487
-
Reactive Streams
5488
-
<details class="invalid-tag">
5489
-
<summary>invalid reference</summary>
5490
-
<pre><code>Publisher</code></pre>
5491
-
</details>
5492
-
.</div>
5472
+
Reactive Streams <a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Publisher.html" title="class or interface in java.util.concurrent" class="external-link"><code>Publisher</code></a>.</div>
<div class="block">Default wrappers and implementations for
5510
-
<details class="invalid-tag">
5511
-
<summary>invalid reference</summary>
5512
-
<pre><code>Subscriber</code></pre>
5513
-
</details>
5514
-
-based consumer classes and interfaces,
5489
+
<div class="block">Default wrappers and implementations for <a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="class or interface in java.util.concurrent" class="external-link"><code>Subscriber</code></a>-based consumer classes and interfaces,
5515
5490
including disposable (<a href="io/reactivex/rxjava4/subscribers/DisposableSubscriber.html" title="class in io.reactivex.rxjava4.subscribers"><code>DisposableSubscriber</code></a>) and resource-tracking
5516
5491
(<a href="io/reactivex/rxjava4/subscribers/ResourceSubscriber.html" title="class in io.reactivex.rxjava4.subscribers"><code>ResourceSubscriber</code></a>)
5517
5492
variants and the <a href="io/reactivex/rxjava4/subscribers/TestSubscriber.html" title="class in io.reactivex.rxjava4.subscribers"><code>TestSubscriber</code></a> that allows unit testing
<dt><a href="io/reactivex/rxjava4/exceptions/QueueOverflowException.html" class="type-name-link" title="class in io.reactivex.rxjava4.exceptions">QueueOverflowException</a> - Exception Class in <a href="io/reactivex/rxjava4/exceptions/package-summary.html">io.reactivex.rxjava4.exceptions</a></dt>
7562
7537
<dd>
7563
7538
<div class="block">Indicates an overflow happened because the upstream disregarded backpressure completely or
<a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html#onNext(T)" title="class or interface in java.util.concurrent" class="external-link"><code>Flow.Subscriber.onNext(Object)</code></a> was called concurrently from multiple threads
7569
7540
without synchronization.</div>
7570
7541
</dd>
7571
7542
<dt><a href="io/reactivex/rxjava4/exceptions/QueueOverflowException.html#%3Cinit%3E()" class="member-name-link">QueueOverflowException()</a> - Constructor for exception class io.reactivex.rxjava4.exceptions.<a href="io/reactivex/rxjava4/exceptions/QueueOverflowException.html" title="class in io.reactivex.rxjava4.exceptions">QueueOverflowException</a></dt>
<dt><a href="io/reactivex/rxjava4/core/FlowableOnSubscribe.html#subscribe(io.reactivex.rxjava4.core.FlowableEmitter)" class="member-name-link">subscribe(FlowableEmitter)</a> - Method in interface io.reactivex.rxjava4.core.<a href="io/reactivex/rxjava4/core/FlowableOnSubscribe.html" title="interface in io.reactivex.rxjava4.core">FlowableOnSubscribe</a></dt>
9373
9344
<dd>
9374
-
<div class="block">Called for each
9375
-
<details class="invalid-tag">
9376
-
<summary>invalid reference</summary>
9377
-
<pre><code>Subscriber</code></pre>
9378
-
</details>
9379
-
that subscribes.</div>
9345
+
<div class="block">Called for each <a href="https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/Flow.Subscriber.html" title="class or interface in java.util.concurrent" class="external-link"><code>Subscriber</code></a> that subscribes.</div>
9380
9346
</dd>
9381
9347
<dt><a href="io/reactivex/rxjava4/core/Flowable.html#subscribe(io.reactivex.rxjava4.core.FlowableSubscriber)" class="member-name-link">subscribe(FlowableSubscriber)</a> - 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>
0 commit comments