Modifier and Type	Class and Description
pack-priv static class	FluxConcatIterable.ConcatIterableSubscriber<T>

Modifier and Type

Class and Description

pack-priv static class

FluxConcatIterable.ConcatIterableSubscriber<T>

Modifier and Type	Field and Description
pack-priv final Iterable<? extends Publisher<? extends T>>	iterable

Modifier and Type

Field and Description

pack-priv final Iterable<? extends Publisher<? extends T>>

iterable

Access	Constructor and Description
pack-priv	FluxConcatIterable(Iterable<? extends Publisher<? extends T>> iterable)

Access

Constructor and Description

pack-priv

FluxConcatIterable(Iterable<? extends Publisher<? extends T>> iterable)

Modifier and Type	Method and Description
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Overrides default reactor.core.publisher.SourceProducer.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public void	subscribe(CoreSubscriber<? super T> the `Subscriber` interested into the published sequence actual) Implements abstract reactor.core.publisher.Flux.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.

Modifier and Type

Method and Description

public Object

scanUnsafe(Scannable.Attr<T>

a Attr to resolve for the component.

key)

Overrides default reactor.core.publisher.SourceProducer.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place.

iterable	back to summary
pack-priv final Iterable<? extends Publisher<? extends T>> iterable

iterable

back to summary

pack-priv final Iterable<? extends Publisher<? extends T>> iterable

FluxConcatIterable	back to summary
pack-priv FluxConcatIterable(Iterable<? extends Publisher<? extends T>> iterable)

FluxConcatIterable

back to summary

pack-priv FluxConcatIterable(Iterable<? extends Publisher<? extends T>> iterable)

Method Detail

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Overrides default reactor.core.publisher.SourceProducer.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

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

Overrides default reactor.core.publisher.SourceProducer.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

subscribe back to summary

subscribe	back to summary
public void subscribe(CoreSubscriber<? super T> actual) Implements abstract reactor.core.publisher.Flux.subscribe. Implements reactor.core.CorePublisher.subscribe. Doc from reactor.core.publisher.Flux.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut. In addition to behave as expected by `Publisher#subscribe(Subscriber)` in a controlled manner, it supports direct subscribe-time `Context` passing. Parameters actual:CoreSubscriber<? super T> the `Subscriber` interested into the published sequence Annotations @Override

public void subscribe(CoreSubscriber<? super T> actual)

Implements abstract reactor.core.publisher.Flux.subscribe.

Implements reactor.core.CorePublisher.subscribe.

Doc from reactor.core.publisher.Flux.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.

In addition to behave as expected by Publisher#subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.

Parameters

actual:CoreSubscriber<? super T>: the Subscriber interested into the published sequence

Annotations

@Override

reactor.core.publisher back to summary

pack-priv final Class FluxConcatIterable.ConcatIterableSubscriber<T>

Class Inheritance

extends Operators.MultiSubscriptionSubscriber<T, T>

java.lang.Object
reactor.core.publisher.Operators.MultiSubscriptionSubscriber
reactor.core.publisher.FluxConcatIterable.ConcatIterableSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final Iterator<? extends Publisher<? extends T>>	it
pack-priv long	produced
pack-priv volatile int	wip Hides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.wip.
pack-priv static final AtomicIntegerFieldUpdater<FluxConcatIterable.ConcatIterableSubscriber<T>>	WIP Hides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.WIP.

Inherited from reactor.core.publisher.Operators.MultiSubscriptionSubscriber:: actual cancelled MISSED_PRODUCED MISSED_REQUESTED MISSED_SUBSCRIPTION missedProduced missedRequested missedSubscription requested subscription unbounded

Constructor Summary

Access	Constructor and Description
pack-priv	ConcatIterableSubscriber(CoreSubscriber<? super T> actual, Iterator<? extends Publisher<? extends T>> it)

Method Summary

Modifier and Type	Method and Description
public void	onComplete() Overrides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.onComplete. Implements org.reactivestreams.Subscriber.onComplete. Successful 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 Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Overrides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.scanUnsafe. Overrides default reactor.core.publisher.InnerProducer.scanUnsafe. Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.

Inherited from reactor.core.publisher.Operators.MultiSubscriptionSubscriber:: actual cancel drain drainLoop isCancelled isUnbounded onError onSubscribe produced producedOne request set shouldCancelCurrent

Field Detail

it	back to summary
pack-priv final Iterator<? extends Publisher<? extends T>> it

produced	back to summary
pack-priv long produced

wip	back to summary
pack-priv volatile int wip Hides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.wip.

WIP	back to summary
pack-priv static final AtomicIntegerFieldUpdater<FluxConcatIterable.ConcatIterableSubscriber<T>> WIP Hides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.WIP. Annotations @SuppressWarnings:rawtypes

Constructor Detail

ConcatIterableSubscriber	back to summary
pack-priv ConcatIterableSubscriber(CoreSubscriber<? super T> actual, Iterator<? extends Publisher<? extends T>> it)

Method Detail

onComplete back to summary

onComplete	back to summary
public void onComplete() Overrides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.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()

Overrides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.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

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

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Overrides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.scanUnsafe. Overrides default reactor.core.publisher.InnerProducer.scanUnsafe. 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

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

Overrides reactor.core.publisher.Operators.MultiSubscriptionSubscriber.scanUnsafe.

Overrides default reactor.core.publisher.InnerProducer.scanUnsafe.

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

pack-priv final Class FluxConcatIterable<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class FluxConcatIterable.ConcatIterableSubscriber<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail