Modifier and Type	Class and Description
pack-priv static class	ObservableFromStream.StreamDisposable<T>

Modifier and Type

Class and Description

pack-priv static class

ObservableFromStream.StreamDisposable<T>

Modifier and Type	Field and Description
pack-priv final Stream<T>	stream

Modifier and Type

Field and Description

pack-priv final Stream<T>

stream

Access	Constructor and Description
public	ObservableFromStream(Stream<T> stream)

Access

Constructor and Description

public

ObservableFromStream(Stream<T> stream)

Modifier and Type	Method and Description
pack-priv static void	closeSafely(AutoCloseable c)
protected void	subscribeActual(Observer<? super T> observer)
public static < the element type of the flow T> void	subscribeStream(Observer<? super T> the observer to drive observer, Stream<T> the sequence to consume stream) Subscribes to the Stream.

Modifier and Type

Method and Description

pack-priv static void

closeSafely(AutoCloseable c)

protected void

subscribeActual(Observer<? super T> observer)

public static <

the element type of the flow

T> void

subscribeStream(Observer<? super T>

the observer to drive

observer, Stream<T>

the sequence to consume

stream)

Subscribes to the Stream.

stream	back to summary
pack-priv final Stream<T> stream

stream

back to summary

pack-priv final Stream<T> stream

ObservableFromStream	back to summary
public ObservableFromStream(Stream<T> stream)

ObservableFromStream

back to summary

public ObservableFromStream(Stream<T> stream)

Method Detail

closeSafely	back to summary
pack-priv static void closeSafely(AutoCloseable c)

closeSafely

back to summary

pack-priv static void closeSafely(AutoCloseable c)

subscribeActual	back to summary
protected void subscribeActual(Observer<? super T> observer) Annotations @Override

subscribeActual

back to summary

protected void subscribeActual(Observer<? super T> observer)

Annotations

@Override

subscribeStream	back to summary
public static <T> void subscribeStream(Observer<? super T> observer, Stream<T> stream) Subscribes to the Stream. Parameters <T> the element type of the flow observer:Observer<? super T> the observer to drive stream:Stream<T> the sequence to consume

subscribeStream

back to summary

public static <T> void subscribeStream(Observer<? super T> observer, Stream<T> stream)

Subscribes to the Stream.

Parameters

<T>: the element type of the flow
observer:Observer<? super T>: the observer to drive
stream:Stream<T>: the sequence to consume

io.reactivex.rxjava3.internal.jdk8 back to summary

pack-priv final Class ObservableFromStream.StreamDisposable<T>

Class Inheritance

extends Object
implements QueueDisposable<T>

java.lang.Object
io.reactivex.rxjava3.internal.jdk8.ObservableFromStream.StreamDisposable

All Implemented Interfaces

io.reactivex.rxjava3.operators.QueueDisposable, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.operators.QueueFuseable, io.reactivex.rxjava3.operators.SimpleQueue

Field Summary

Modifier and Type	Field and Description
pack-priv AutoCloseable	closeable
pack-priv volatile boolean	disposed
pack-priv final Observer<? super T>	downstream
pack-priv Iterator<T>	iterator
pack-priv boolean	once
pack-priv boolean	outputFused

Constructor Summary

Access	Constructor and Description
pack-priv	StreamDisposable(Observer<? super T> downstream, Iterator<T> iterator, AutoCloseable closeable)

Method Summary

Modifier and Type	Method and Description
public void	clear() Implements io.reactivex.rxjava3.operators.SimpleQueue.clear. Removes all enqueued items from this queue.
public void	dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public boolean	isEmpty() Implements io.reactivex.rxjava3.operators.SimpleQueue.isEmpty. Returns true if the queue is empty.
public boolean	offer(T the value to enqueue, not null value) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue a single value.
public boolean	offer(T the first value to enqueue, not null v1, T the second value to enqueue, not null v2) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue two values.
public T	poll() Implements io.reactivex.rxjava3.operators.SimpleQueue.poll. Tries to dequeue a value (non-null) or returns null if the queue is empty.
public int	requestFusion(int the requested fusion mode, allowed values are `SYNC`, `ASYNC`, `ANY` combined with `BOUNDARY` (e.g., `requestFusion(SYNC \| BOUNDARY)`). mode) Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion. Request a fusion mode from the upstream.
public void	run()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

closeable	back to summary
pack-priv AutoCloseable closeable

disposed	back to summary
pack-priv volatile boolean disposed

downstream	back to summary
pack-priv final Observer<? super T> downstream

iterator	back to summary
pack-priv Iterator<T> iterator

once	back to summary
pack-priv boolean once

outputFused	back to summary
pack-priv boolean outputFused

Constructor Detail

StreamDisposable	back to summary
pack-priv StreamDisposable(Observer<? super T> downstream, Iterator<T> iterator, AutoCloseable closeable)

Method Detail

clear	back to summary
public void clear() Implements io.reactivex.rxjava3.operators.SimpleQueue.clear. Doc from io.reactivex.rxjava3.operators.SimpleQueue.clear. Removes all enqueued items from this queue. Annotations @Override

clear

back to summary

public void clear()

Implements io.reactivex.rxjava3.operators.SimpleQueue.clear.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.clear.

Removes all enqueued items from this queue.

Annotations

@Override

dispose	back to summary
public void dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Doc from io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations

@Override

isEmpty back to summary

isEmpty	back to summary
public boolean isEmpty() Implements io.reactivex.rxjava3.operators.SimpleQueue.isEmpty. Doc from io.reactivex.rxjava3.operators.SimpleQueue.isEmpty. Returns true if the queue is empty. Note however that due to potential fused functions in `poll()` it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s). Returns:boolean true if the queue is empty Annotations @Override

public boolean isEmpty()

Implements io.reactivex.rxjava3.operators.SimpleQueue.isEmpty.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.isEmpty.

Returns true if the queue is empty.

Note however that due to potential fused functions in poll() it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s).

Returns:boolean

true if the queue is empty

Annotations

@Override

offer	back to summary
public boolean offer(T value) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Doc from io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue a single value. Parameters value:T the value to enqueue, not null Returns:boolean true if successful, false if the value was not enqueued likely due to reaching the queue capacity) Annotations @Override

offer

back to summary

public boolean offer(T value)

Implements io.reactivex.rxjava3.operators.SimpleQueue.offer.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.offer.

Atomically enqueue a single value.

Parameters

value:T: the value to enqueue, not null

Returns:boolean

true if successful, false if the value was not enqueued likely due to reaching the queue capacity)

Annotations

@Override

offer	back to summary
public boolean offer(T v1, T v2) Implements io.reactivex.rxjava3.operators.SimpleQueue.offer. Doc from io.reactivex.rxjava3.operators.SimpleQueue.offer. Atomically enqueue two values. Parameters v1:T the first value to enqueue, not null v2:T the second value to enqueue, not null Returns:boolean true if successful, false if the value was not enqueued likely due to reaching the queue capacity) Annotations @Override

offer

back to summary

public boolean offer(T v1, T v2)

Implements io.reactivex.rxjava3.operators.SimpleQueue.offer.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.offer.

Atomically enqueue two values.

Parameters

v1:T: the first value to enqueue, not null
v2:T: the second value to enqueue, not null

Returns:boolean

true if successful, false if the value was not enqueued likely due to reaching the queue capacity)

Annotations

@Override

poll back to summary

poll	back to summary
public T poll() Implements io.reactivex.rxjava3.operators.SimpleQueue.poll. Doc from io.reactivex.rxjava3.operators.SimpleQueue.poll. Tries to dequeue a value (non-null) or returns null if the queue is empty. If the producer uses `offer(Object, Object)` and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well. Returns:T the item or null to indicate an empty queue Annotations @Nullable @Override

public T poll()

Implements io.reactivex.rxjava3.operators.SimpleQueue.poll.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.

If the producer uses offer(Object, Object) and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.

Returns:T

the item or null to indicate an empty queue

Annotations

@Nullable
@Override

requestFusion back to summary

requestFusion	back to summary
public int requestFusion(int mode) Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion. Doc from io.reactivex.rxjava3.operators.QueueFuseable.requestFusion. Request a fusion mode from the upstream. This should be called before `onSubscribe` returns. Calling this method multiple times or after `onSubscribe` finished is not allowed and may result in undefined behavior. Parameters mode:int the requested fusion mode, allowed values are `SYNC`, `ASYNC`, `ANY` combined with `BOUNDARY` (e.g., `requestFusion(SYNC \| BOUNDARY)`). Returns:int the established fusion mode: `NONE`, `SYNC`, `ASYNC`. Annotations @Override

public int requestFusion(int mode)

Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion.

Doc from io.reactivex.rxjava3.operators.QueueFuseable.requestFusion.

Request a fusion mode from the upstream.

This should be called before onSubscribe returns.

Calling this method multiple times or after onSubscribe finished is not allowed and may result in undefined behavior.

Parameters

mode:int: the requested fusion mode, allowed values are SYNC, ASYNC, ANY combined with BOUNDARY (e.g., requestFusion(SYNC | BOUNDARY)).

Returns:int

the established fusion mode: NONE, SYNC, ASYNC.

Annotations

@Override

run	back to summary
public void run()

public final Class ObservableFromStream<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableFromStream.StreamDisposable<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail