Modifier and Type	Class and Description
pack-priv static class	BlockingIterable.SubscriberIterator<T>

Access	Constructor and Description
pack-priv	BlockingIterable(CorePublisher<? extends T> source, int batchSize, Supplier<Queue<T>> queueSupplier, Supplier<Context> contextSupplier)

Modifier and Type	Method and Description
pack-priv BlockingIterable.SubscriberIterator<T>	createIterator()
public Iterator<T>	iterator() Implements java.lang.Iterable.iterator. Returns an iterator over elements of type `T`.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public Spliterator<T>	spliterator() Overrides default java.lang.Iterable.spliterator. Creates a `Spliterator` over the elements described by this `Iterable`.
public Stream<T>	Returns: a `Stream` of unknown size with onClose attached to `Subscription#cancel()` stream()

batchSize	back to summary
pack-priv final int batchSize

contextSupplier	back to summary
pack-priv final Supplier<Context> contextSupplier

queueSupplier	back to summary
pack-priv final Supplier<Queue<T>> queueSupplier

source	back to summary
pack-priv final CorePublisher<? extends T> source

BlockingIterable	back to summary
pack-priv BlockingIterable(CorePublisher<? extends T> source, int batchSize, Supplier<Queue<T>> queueSupplier, Supplier<Context> contextSupplier)

Method Detail

createIterator	back to summary
pack-priv BlockingIterable.SubscriberIterator<T> createIterator()

iterator back to summary

iterator	back to summary
public Iterator<T> iterator() Implements java.lang.Iterable.iterator. Doc from java.lang.Iterable.iterator. Returns an iterator over elements of type `T`. Returns:Iterator<T> an Iterator. Annotations @Override

public Iterator<T> iterator()

Implements java.lang.Iterable.iterator.

Doc from java.lang.Iterable.iterator.

Returns an iterator over elements of type T.

Returns:Iterator<T>

an Iterator.

Annotations

@Override

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Implements reactor.core.Scannable.scanUnsafe. Doc from reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the `Attr` key, implementors should take care to return values of the correct type, and return null if no specific value is available. For public consumption of attributes, prefer using `scan(Attr)`, which will return a typed value and fall back to the key's default if the component didn't define any mapping. Parameters key:Scannable.Attr<T> a `Attr` to resolve for the component. Returns:Object the value associated to the key for that specific component, or null if none. Annotations @Override @Nullable

public Object scanUnsafe(Scannable.Attr<T> key)

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override
@Nullable

spliterator back to summary

spliterator	back to summary
public Spliterator<T> spliterator() Overrides default java.lang.Iterable.spliterator. Doc from java.lang.Iterable.spliterator. Creates a `Spliterator` over the elements described by this `Iterable`. Returns:Spliterator<T> a `Spliterator` over the elements described by this `Iterable`. Annotations @Override

public Spliterator<T> spliterator()

Overrides default java.lang.Iterable.spliterator.

Doc from java.lang.Iterable.spliterator.

Creates a Spliterator over the elements described by this Iterable.

Returns:Spliterator<T>

a Spliterator over the elements described by this Iterable.

Annotations

@Override

stream	back to summary
public Stream<T> stream() Returns:Stream<T> a `Stream` of unknown size with onClose attached to `Subscription#cancel()`

reactor.core.publisher back to summary

pack-priv final Class BlockingIterable.SubscriberIterator<T>

Class Inheritance

extends Object
implements InnerConsumer<T>, Iterator<T>, Runnable

java.lang.Object
reactor.core.publisher.BlockingIterable.SubscriberIterator

All Implemented Interfaces

java.lang.Runnable, java.util.Iterator, reactor.core.publisher.InnerConsumer, reactor.core.Scannable, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final int	batchSize
pack-priv final Condition	condition
pack-priv final Context	context
pack-priv volatile boolean	done
pack-priv Throwable	error
pack-priv final int	limit
pack-priv final Lock	lock
pack-priv long	produced
pack-priv final Queue<T>	queue
pack-priv volatile Subscription	s
pack-priv static final AtomicReferenceFieldUpdater<BlockingIterable.SubscriberIterator<T>, Subscription>	S

Constructor Summary

Access	Constructor and Description
pack-priv	SubscriberIterator(Queue<T> queue, Context context, int batchSize)

Method Summary

Modifier and Type	Method and Description
public Context	currentContext() Overrides default reactor.core.CoreSubscriber.currentContext. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `org.reactivestreams.Subscriber`.
public boolean	hasNext() Implements java.util.Iterator.hasNext. Returns `true` if the iteration has more elements.
public T	next() Implements java.util.Iterator.next. Returns the next element in the iteration.
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onError(Throwable the throwable signaled t) Implements org.reactivestreams.Subscriber.onError. Failed terminal state.
public void	onNext(T the element signaled t) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Implements reactor.core.CoreSubscriber.onSubscribe. Implementors should initialize any state used by `onNext(Object)` before calling `Subscription#request(long)`.
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
pack-priv void	signalConsumer()

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

Field Detail

batchSize	back to summary
pack-priv final int batchSize

condition	back to summary
pack-priv final Condition condition

context	back to summary
pack-priv final Context context

done	back to summary
pack-priv volatile boolean done

error	back to summary
pack-priv Throwable error

limit	back to summary
pack-priv final int limit

lock	back to summary
pack-priv final Lock lock

produced	back to summary
pack-priv long produced

queue	back to summary
pack-priv final Queue<T> queue

s	back to summary
pack-priv volatile Subscription s

S	back to summary
pack-priv static final AtomicReferenceFieldUpdater<BlockingIterable.SubscriberIterator<T>, Subscription> S Annotations @SuppressWarnings:rawtypes

Constructor Detail

SubscriberIterator	back to summary
pack-priv SubscriberIterator(Queue<T> queue, Context context, int batchSize)

Method Detail

currentContext back to summary

currentContext	back to summary
public Context currentContext() Overrides default reactor.core.CoreSubscriber.currentContext. Doc from reactor.core.CoreSubscriber.currentContext. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `org.reactivestreams.Subscriber`. Returns:Context a resolved context or `Context#empty()` Annotations @Override

public Context currentContext()

Overrides default reactor.core.CoreSubscriber.currentContext.

Doc from reactor.core.CoreSubscriber.currentContext.

Request a Context from dependent components which can include downstream operators during subscribing or a terminal org.reactivestreams.Subscriber.

Returns:Context

a resolved context or Context#empty()

Annotations

@Override

hasNext back to summary

hasNext	back to summary
public boolean hasNext() Implements java.util.Iterator.hasNext. Doc from java.util.Iterator.hasNext. Returns `true` if the iteration has more elements. (In other words, returns `true` if `next` would return an element rather than throwing an exception.) Returns:boolean `true` if the iteration has more elements Annotations @Override

public boolean hasNext()

Implements java.util.Iterator.hasNext.

Doc from java.util.Iterator.hasNext.

Returns true if the iteration has more elements. (In other words, returns true if next would return an element rather than throwing an exception.)

Returns:boolean

true if the iteration has more elements

Annotations

@Override

next	back to summary
public T next() Implements java.util.Iterator.next. Doc from java.util.Iterator.next. Returns the next element in the iteration. Returns:T the next element in the iteration Annotations @Override

back to summary

public T next()

Implements java.util.Iterator.next.

Doc from java.util.Iterator.next.

Returns the next element in the iteration.

Returns:T

the next element in the iteration

Annotations

@Override

onComplete back to summary

onComplete	back to summary
public void onComplete() Implements org.reactivestreams.Subscriber.onComplete. Doc from org.reactivestreams.Subscriber.onComplete. Successful terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Annotations @Override

public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable t) Implements org.reactivestreams.Subscriber.onError. Doc from org.reactivestreams.Subscriber.onError. Failed terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Parameters t:Throwable the throwable signaled Annotations @Override

public void onError(Throwable t)

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters

t:Throwable: the throwable signaled

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements org.reactivestreams.Subscriber.onNext. Doc from org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`. Parameters t:T the element signaled Annotations @Override

public void onNext(T t)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

t:T: the element signaled

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Subscription s) Implements reactor.core.CoreSubscriber.onSubscribe. Doc from reactor.core.CoreSubscriber.onSubscribe. Implementors should initialize any state used by `onNext(Object)` before calling `Subscription#request(long)`. Should further `onNext` related state modification occur, thread-safety will be required. Note that an invalid request `<= 0` will not produce an onError and will simply be ignored or reported through a debug-enabled `reactor.util.Logger`. Invoked after calling `Publisher#subscribe(Subscriber)`. No data will start flowing until `Subscription#request(long)` is invoked. It is the responsibility of this `Subscriber` instance to call `Subscription#request(long)` whenever more data is wanted. The `Publisher` will send notifications only in response to `Subscription#request(long)`. Parameters s:Subscription Doc from org.reactivestreams.Subscriber.onSubscribe. the `Subscription` that allows requesting data via `Subscription#request(long)` Annotations @Override

public void onSubscribe(Subscription s)

Implements reactor.core.CoreSubscriber.onSubscribe.

Doc from reactor.core.CoreSubscriber.onSubscribe.

Implementors should initialize any state used by onNext(Object) before calling Subscription#request(long). Should further onNext related state modification occur, thread-safety will be required.

Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled reactor.util.Logger. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters

s:Subscription

Doc from org.reactivestreams.Subscriber.onSubscribe.

the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Implements reactor.core.Scannable.scanUnsafe. Doc from reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the `Attr` key, implementors should take care to return values of the correct type, and return null if no specific value is available. For public consumption of attributes, prefer using `scan(Attr)`, which will return a typed value and fall back to the key's default if the component didn't define any mapping. Parameters key:Scannable.Attr<T> a `Attr` to resolve for the component. Returns:Object the value associated to the key for that specific component, or null if none. Annotations @Override @Nullable

public Object scanUnsafe(Scannable.Attr<T> key)

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>: a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations

@Override
@Nullable

signalConsumer	back to summary
pack-priv void signalConsumer()

pack-priv final Class BlockingIterable<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class BlockingIterable.SubscriberIterator<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

Modifier and Type	Field and Description
pack-priv final int	batchSize
pack-priv final Supplier<Context>	contextSupplier
pack-priv final Supplier<Queue<T>>	queueSupplier
pack-priv final CorePublisher<? extends T>	source