@@ -155,7 +155,7 @@ <h3 id="methods-inherited-from-class-java.lang.Object">Methods inherited from cl
155155< code > < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#clone() " title ="clone() " class ="external-link "> clone</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#equals(java.lang.Object) " title ="equals(Object) " class ="external-link "> equals</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#finalize() " title ="finalize() " class ="external-link "> finalize</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#getClass() " title ="getClass() " class ="external-link "> getClass</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#hashCode() " title ="hashCode() " class ="external-link "> hashCode</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#notify() " title ="notify() " class ="external-link "> notify</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#notifyAll() " title ="notifyAll() " class ="external-link "> notifyAll</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#toString() " title ="toString() " class ="external-link "> toString</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#wait() " title ="wait() " class ="external-link "> wait</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#wait(long) " title ="wait(long) " class ="external-link "> wait</ a > , < a href ="https://docs.oracle.com/en/java/javase/26/docs/api/java.base/java/lang/Object.html#wait(long,int) " title ="wait(long, int) " class ="external-link "> wait</ a > </ code > </ div >
156156< div class ="inherited-list ">
157157< h3 id ="methods-inherited-from-class-io.reactivex.rxjava4.core.Streamable "> Methods inherited from interface < a href ="Streamable.html#method-summary " title ="interface in io.reactivex.rxjava4.core "> Streamable</ a > </ h3 >
158- < code > < a href ="Streamable.html#blockingFirst() " title ="blockingFirst() "> blockingFirst</ a > , < a href ="Streamable.html#blockingLast() " title ="blockingLast() "> blockingLast</ a > , < a href ="Streamable.html#collect(java.util.stream.Collector) " title ="collect(Collector) "> collect</ a > , < a href ="Streamable.html#delay(long,java.util.concurrent.TimeUnit,io.reactivex.rxjava4.core.Scheduler) " title ="delay(long, TimeUnit, Scheduler) "> delay</ a > , < a href ="Streamable.html#doOnError(io.reactivex.rxjava4.functions.Consumer) " title ="doOnError(Consumer) "> doOnError</ a > , < a href ="Streamable.html#doOnNext(io.reactivex.rxjava4.functions.Consumer) " title ="doOnNext(Consumer) "> doOnNext</ a > , < a href ="Streamable.html#filter(io.reactivex.rxjava4.functions.Predicate) " title ="filter(Predicate) "> filter</ a > , < a href ="Streamable.html#flatMap(io.reactivex.rxjava4.functions.Function,io.reactivex.rxjava4.core.config.StandardConcurrentConfig) " title ="flatMap(Function, StandardConcurrentConfig) "> flatMap</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.BiConsumer,io.reactivex.rxjava4.disposables.DisposableStreamerCancellation,java.util.concurrent.ExecutorService) " title ="forEach(BiConsumer, DisposableStreamerCancellation, ExecutorService) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer) " title ="forEach(Consumer) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer,io.reactivex.rxjava4.disposables.DisposableStreamerCancellation) " title ="forEach(Consumer, DisposableStreamerCancellation) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer,io.reactivex.rxjava4.disposables.DisposableStreamerCancellation,java.util.concurrent.ExecutorService) " title ="forEach(Consumer, DisposableStreamerCancellation, ExecutorService) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer,java.util.concurrent.ExecutorService) " title ="forEach(Consumer, ExecutorService) "> forEach</ a > , < a href ="Streamable.html#groupBy(io.reactivex.rxjava4.functions.Function) " title ="groupBy(Function) "> groupBy</ a > , < a href ="Streamable.html#hide() " title ="hide() "> hide</ a > , < a href ="Streamable.html#ignoreElements() " title ="ignoreElements() "> ignoreElements</ a > , < a href ="Streamable.html#intercept(io.reactivex.rxjava4.core.config.StreamableInterceptConfig) " title ="intercept(StreamableInterceptConfig) "> intercept</ a > , < a href ="Streamable.html#last(T) " title ="last(T) "> last</ a > , < a href ="Streamable.html#lastOrError() " title ="lastOrError() "> lastOrError</ a > , < a href ="Streamable.html#lift(io.reactivex.rxjava4.core.StreamableOperator) " title ="lift(StreamableOperator) "> lift</ a > , < a href ="Streamable.html#map(io.reactivex.rxjava4.functions.Function) " title ="map(Function) "> map</ a > , < a href ="Streamable.html#mapOptional(io.reactivex.rxjava4.functions.Function) " title ="mapOptional(Function) "> mapOptional</ a > , < a href ="Streamable.html#onErrorResumeNext(io.reactivex.rxjava4.functions.Function) " title ="onErrorResumeNext(Function) "> onErrorResumeNext</ a > , < a href ="Streamable.html#repeat(long) " title ="repeat(long) "> repeat</ a > , < a href ="Streamable.html#repeatWhen(io.reactivex.rxjava4.functions.Function) " title ="repeatWhen(Function) "> repeatWhen</ a > , < a href ="Streamable.html#retry(long) " title ="retry(long) "> retry</ a > , < a href ="Streamable.html#retry(io.reactivex.rxjava4.functions.BiPredicate) " title ="retry(BiPredicate) "> retry</ a > , < a href ="Streamable.html#retry(io.reactivex.rxjava4.functions.Predicate) " title ="retry(Predicate) "> retry</ a > , < a href ="Streamable.html#retryWhen(io.reactivex.rxjava4.functions.BiFunction) " title ="retryWhen(BiFunction) "> retryWhen</ a > , < a href ="Streamable.html#skip(long) " title ="skip(long) "> skip</ a > , < a href ="Streamable.html#stream(io.reactivex.rxjava4.disposables.StreamerCancellation) " title ="stream(StreamerCancellation) "> stream</ a > , < a href ="Streamable.html#subscribe(io.reactivex.rxjava4.core.StreamSink) " title ="subscribe(StreamSink) "> subscribe</ a > , < a href ="Streamable.html#subscribe(io.reactivex.rxjava4.core.StreamSink,java.util.concurrent.ExecutorService) " title ="subscribe(StreamSink, ExecutorService) "> subscribe</ a > , < a href ="Streamable.html#subscribe(java.util.concurrent.Flow.Subscriber) " title ="subscribe(Flow.Subscriber) "> subscribe</ a > , < a href ="Streamable.html#subscribe(java.util.concurrent.Flow.Subscriber,java.util.concurrent.ExecutorService) " title ="subscribe(Flow.Subscriber, ExecutorService) "> subscribe</ a > , < a href ="Streamable.html#take(long) " title ="take(long) "> take</ a > , < a href ="Streamable.html#takeUntil(io.reactivex.rxjava4.core.Streamable) " title ="takeUntil(Streamable) "> takeUntil</ a > , < a href ="Streamable.html#takeWhile(io.reactivex.rxjava4.functions.Predicate) " title ="takeWhile(Predicate) "> takeWhile</ a > , < a href ="Streamable.html#test() " title ="test() "> test</ a > , < a href ="Streamable.html#test(java.util.concurrent.ExecutorService) " title ="test(ExecutorService) "> test</ a > , < a href ="Streamable.html#timeout(long,java.util.concurrent.TimeUnit,io.reactivex.rxjava4.core.Scheduler,io.reactivex.rxjava4.core.Streamable) " title ="timeout(long, TimeUnit, Scheduler, Streamable) "> timeout</ a > , < a href ="Streamable.html#to(io.reactivex.rxjava4.core.StreamableConverter) " title ="to(StreamableConverter) "> to</ a > , < a href ="Streamable.html#toFlowable() " title ="toFlowable() "> toFlowable</ a > , < a href ="Streamable.html#toFlowable(java.util.concurrent.ExecutorService) " title ="toFlowable(ExecutorService) "> toFlowable</ a > , < a href ="Streamable.html#toObservable() " title ="toObservable() "> toObservable</ a > , < a href ="Streamable.html#transform(io.reactivex.rxjava4.core.VirtualTransformer) " title ="transform(VirtualTransformer) "> transform</ a > , < a href ="Streamable.html#transform(io.reactivex.rxjava4.core.VirtualTransformer,java.util.concurrent.ExecutorService) " title ="transform(VirtualTransformer, ExecutorService) "> transform</ a > </ code >
158+ < code > < a href ="Streamable.html#blockingFirst() " title ="blockingFirst() "> blockingFirst</ a > , < a href ="Streamable.html#blockingFirst(io.reactivex.rxjava4.disposables.StreamerCancellation) " title ="blockingFirst(StreamerCancellation) "> blockingFirst</ a > , < a href ="Streamable.html#blockingLast() " title ="blockingLast() "> blockingLast</ a > , < a href ="Streamable.html#blockingLast(io.reactivex.rxjava4.disposables.StreamerCancellation) " title ="blockingLast(StreamerCancellation) "> blockingLast</ a > , < a href ="Streamable.html#collect(java.util.stream.Collector) " title ="collect(Collector) "> collect</ a > , < a href ="Streamable.html#delay(long,java.util.concurrent.TimeUnit,io.reactivex.rxjava4.core.Scheduler) " title ="delay(long, TimeUnit, Scheduler) "> delay</ a > , < a href ="Streamable.html#doOnError(io.reactivex.rxjava4.functions.Consumer) " title ="doOnError(Consumer) "> doOnError</ a > , < a href ="Streamable.html#doOnNext(io.reactivex.rxjava4.functions.Consumer) " title ="doOnNext(Consumer) "> doOnNext</ a > , < a href ="Streamable.html#filter(io.reactivex.rxjava4.functions.Predicate) " title ="filter(Predicate) "> filter</ a > , < a href ="Streamable.html#flatMap(io.reactivex.rxjava4.functions.Function,io.reactivex.rxjava4.core.config.StandardConcurrentConfig) " title ="flatMap(Function, StandardConcurrentConfig) "> flatMap</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.BiConsumer,io.reactivex.rxjava4.disposables.DisposableStreamerCancellation,java.util.concurrent.ExecutorService) " title ="forEach(BiConsumer, DisposableStreamerCancellation, ExecutorService) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer) " title ="forEach(Consumer) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer,io.reactivex.rxjava4.disposables.DisposableStreamerCancellation) " title ="forEach(Consumer, DisposableStreamerCancellation) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer,io.reactivex.rxjava4.disposables.DisposableStreamerCancellation,java.util.concurrent.ExecutorService) " title ="forEach(Consumer, DisposableStreamerCancellation, ExecutorService) "> forEach</ a > , < a href ="Streamable.html#forEach(io.reactivex.rxjava4.functions.Consumer,java.util.concurrent.ExecutorService) " title ="forEach(Consumer, ExecutorService) "> forEach</ a > , < a href ="Streamable.html#groupBy(io.reactivex.rxjava4.functions.Function) " title ="groupBy(Function) "> groupBy</ a > , < a href ="Streamable.html#hide() " title ="hide() "> hide</ a > , < a href ="Streamable.html#ignoreElements() " title ="ignoreElements() "> ignoreElements</ a > , < a href ="Streamable.html#intercept(io.reactivex.rxjava4.core.config.StreamableInterceptConfig) " title ="intercept(StreamableInterceptConfig) "> intercept</ a > , < a href ="Streamable.html#last(T) " title ="last(T) "> last</ a > , < a href ="Streamable.html#lastOrError() " title ="lastOrError() "> lastOrError</ a > , < a href ="Streamable.html#lift(io.reactivex.rxjava4.core.StreamableOperator) " title ="lift(StreamableOperator) "> lift</ a > , < a href ="Streamable.html#map(io.reactivex.rxjava4.functions.Function) " title ="map(Function) "> map</ a > , < a href ="Streamable.html#mapOptional(io.reactivex.rxjava4.functions.Function) " title ="mapOptional(Function) "> mapOptional</ a > , < a href ="Streamable.html#onErrorResumeNext(io.reactivex.rxjava4.functions.Function) " title ="onErrorResumeNext(Function) "> onErrorResumeNext</ a > , < a href ="Streamable.html#repeat(long) " title ="repeat(long) "> repeat</ a > , < a href ="Streamable.html#repeatWhen(io.reactivex.rxjava4.functions.Function) " title ="repeatWhen(Function) "> repeatWhen</ a > , < a href ="Streamable.html#retry(long) " title ="retry(long) "> retry</ a > , < a href ="Streamable.html#retry(io.reactivex.rxjava4.functions.BiPredicate) " title ="retry(BiPredicate) "> retry</ a > , < a href ="Streamable.html#retry(io.reactivex.rxjava4.functions.Predicate) " title ="retry(Predicate) "> retry</ a > , < a href ="Streamable.html#retryWhen(io.reactivex.rxjava4.functions.BiFunction) " title ="retryWhen(BiFunction) "> retryWhen</ a > , < a href ="Streamable.html#skip(long) " title ="skip(long) "> skip</ a > , < a href ="Streamable.html#stream(io.reactivex.rxjava4.disposables.StreamerCancellation) " title ="stream(StreamerCancellation) "> stream</ a > , < a href ="Streamable.html#subscribe(io.reactivex.rxjava4.core.StreamSink) " title ="subscribe(StreamSink) "> subscribe</ a > , < a href ="Streamable.html#subscribe(io.reactivex.rxjava4.core.StreamSink,java.util.concurrent.ExecutorService) " title ="subscribe(StreamSink, ExecutorService) "> subscribe</ a > , < a href ="Streamable.html#subscribe(java.util.concurrent.Flow.Subscriber) " title ="subscribe(Flow.Subscriber) "> subscribe</ a > , < a href ="Streamable.html#subscribe(java.util.concurrent.Flow.Subscriber,java.util.concurrent.ExecutorService) " title ="subscribe(Flow.Subscriber, ExecutorService) "> subscribe</ a > , < a href ="Streamable.html#take(long) " title ="take(long) "> take</ a > , < a href ="Streamable.html#takeUntil(io.reactivex.rxjava4.core.Streamable) " title ="takeUntil(Streamable) "> takeUntil</ a > , < a href ="Streamable.html#takeWhile(io.reactivex.rxjava4.functions.Predicate) " title ="takeWhile(Predicate) "> takeWhile</ a > , < a href ="Streamable.html#test() " title ="test() "> test</ a > , < a href ="Streamable.html#test(java.util.concurrent.ExecutorService) " title ="test(ExecutorService) "> test</ a > , < a href ="Streamable.html#timeout(long,java.util.concurrent.TimeUnit,io.reactivex.rxjava4.core.Scheduler,io.reactivex.rxjava4.core.Streamable) " title ="timeout(long, TimeUnit, Scheduler, Streamable) "> timeout</ a > , < a href ="Streamable.html#to(io.reactivex.rxjava4.core.StreamableConverter) " title ="to(StreamableConverter) "> to</ a > , < a href ="Streamable.html#toFlowable() " title ="toFlowable() "> toFlowable</ a > , < a href ="Streamable.html#toFlowable(java.util.concurrent.ExecutorService) " title ="toFlowable(ExecutorService) "> toFlowable</ a > , < a href ="Streamable.html#toObservable() " title ="toObservable() "> toObservable</ a > , < a href ="Streamable.html#transform(io.reactivex.rxjava4.core.VirtualTransformer) " title ="transform(VirtualTransformer) "> transform</ a > , < a href ="Streamable.html#transform(io.reactivex.rxjava4.core.VirtualTransformer,java.util.concurrent.ExecutorService) " title ="transform(VirtualTransformer, ExecutorService) "> transform</ a > </ code >
159159< div class ="summary-table three-column-summary ">
160160< div class ="table-header col-first "> Modifier and Type</ div >
161161< div class ="table-header col-second "> Method</ div >
@@ -166,7 +166,18 @@ <h3 id="methods-inherited-from-class-io.reactivex.rxjava4.core.Streamable">Metho
166166< div class ="block "> Blocks the current thread until this < code > Streamable</ code > produces one item, which is then returned.</ div >
167167</ div >
168168< div class ="col-first odd-row-color "> < code > default < a href ="#type-param-T " title ="type parameter in GroupedStreamable "> T</ a > </ code > </ div >
169- < div class ="col-second odd-row-color "> < code > < a href ="Streamable.html#blockingLast() " class ="member-name-link "> blockingLast</ a > ()</ code > </ div >
169+ < div class ="col-second odd-row-color "> < code > < a href ="Streamable.html#blockingFirst(io.reactivex.rxjava4.disposables.StreamerCancellation) " class ="member-name-link "> blockingFirst</ a > < wbr > (< a href ="../disposables/StreamerCancellation.html " title ="interface in io.reactivex.rxjava4.disposables "> StreamerCancellation</ a > cancellation)</ code > </ div >
170+ < div class ="col-last odd-row-color ">
171+ < div class ="block "> Blocks the current thread until this < code > Streamable</ code > produces one item, which is then returned.</ div >
172+ </ div >
173+ < div class ="col-first even-row-color "> < code > default < a href ="#type-param-T " title ="type parameter in GroupedStreamable "> T</ a > </ code > </ div >
174+ < div class ="col-second even-row-color "> < code > < a href ="Streamable.html#blockingLast() " class ="member-name-link "> blockingLast</ a > ()</ code > </ div >
175+ < div class ="col-last even-row-color ">
176+ < div class ="block "> Blocks the current thread until this < code > Streamable</ code > produces all of its items
177+ and the very last is then returned.</ div >
178+ </ div >
179+ < div class ="col-first odd-row-color "> < code > default < a href ="#type-param-T " title ="type parameter in GroupedStreamable "> T</ a > </ code > </ div >
180+ < div class ="col-second odd-row-color "> < code > < a href ="Streamable.html#blockingLast(io.reactivex.rxjava4.disposables.StreamerCancellation) " class ="member-name-link "> blockingLast</ a > < wbr > (< a href ="../disposables/StreamerCancellation.html " title ="interface in io.reactivex.rxjava4.disposables "> StreamerCancellation</ a > cancellation)</ code > </ div >
170181< div class ="col-last odd-row-color ">
171182< div class ="block "> Blocks the current thread until this < code > Streamable</ code > produces all of its items
172183and the very last is then returned.</ div >
0 commit comments