Top Description Fields Methods
reactor.core.publisher

pack-priv Interface InnerProducer<O>

extends Scannable, Subscription
Known Direct Subinterfaces
reactor.core.publisher.FluxGroupJoin.JoinSupport, reactor.core.publisher.FluxReplay.ReplaySubscription, reactor.core.publisher.InnerOperator, reactor.core.publisher.SinkEmptyMulticast.Inner
Known Direct Implementers
reactor.core.publisher.MonoCallable.MonoCallableSubscription, reactor.core.publisher.MonoCompletionStage.MonoCompletionStageSubscription, reactor.core.publisher.MonoCreate.DefaultMonoSink, reactor.core.publisher.FluxArray.ArraySubscription, reactor.core.publisher.FluxArray.ArrayConditionalSubscription, reactor.core.publisher.FluxCombineLatest.CombineLatestCoordinator, reactor.core.publisher.FluxGenerate.GenerateSubscription, reactor.core.publisher.FluxGroupBy.UnicastGroupedFlux, reactor.core.publisher.FluxInterval.IntervalRunnable, reactor.core.publisher.FluxIterable.IterableSubscription, reactor.core.publisher.FluxIterable.IterableSubscriptionConditional, reactor.core.publisher.FluxMergeComparing.MergeOrderedMainProducer, reactor.core.publisher.MonoSupplier.MonoSupplierSubscription, reactor.core.publisher.FluxWindowTimeout.InnerWindow, reactor.core.publisher.FluxZip.ZipScalarCoordinator, reactor.core.publisher.FluxZip.ZipCoordinator, reactor.core.publisher.MonoDelay.MonoDelayRunnable, reactor.core.publisher.MonoWhen.WhenCoordinator, reactor.core.publisher.MonoZip.ZipCoordinator, reactor.core.publisher.Operators.ScalarSubscription, reactor.core.publisher.Operators.MonoInnerProducerBase, reactor.core.publisher.FluxPublish.PubSubInner, reactor.core.publisher.FluxPublishMulticast.PublishMulticastInner, reactor.core.publisher.FluxRange.RangeSubscription, reactor.core.publisher.FluxRange.RangeSubscriptionConditional, reactor.core.publisher.FluxSubscribeOnCallable.CallableSubscribeOnSubscription, reactor.core.publisher.MonoSequenceEqual.EqualCoordinator, reactor.core.publisher.SinkManyBestEffort.DirectInner, reactor.core.publisher.FluxCreate.BaseSink, reactor.core.publisher.FluxErrorOnRequest.ErrorSubscription, reactor.core.publisher.FluxExpand.ExpandDepthSubscription, reactor.core.publisher.FluxSubscribeOnValue.ScheduledScalar, reactor.core.publisher.MonoPublishMulticast.PublishMulticastInner, reactor.core.publisher.ParallelMergeReduce.MergeReduceMain, reactor.core.publisher.ParallelMergeSequential.MergeSequentialMain, reactor.core.publisher.ParallelMergeSort.MergeSortMain, reactor.core.publisher.ParallelSource.ParallelSourceMain.ParallelSourceInner, reactor.core.publisher.ParallelThen.ThenMain
Type Parameters
<O>
output operator produced type
Imports
org.reactivestreams.Subscriber, .Subscription, reactor.core.CoreSubscriber, .Scannable, reactor.util.annotation.Nullable
InnerProducer is a reactor.core.Scannable Subscription that produces data to an actual() Subscriber
Author
Stephane Maldini

Field Summary

Inherited from reactor.core.Scannable:
OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Method Summary

Modifier and TypeMethod and Description
public CoreSubscriber<? super O>
actual()

public default 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.
Inherited from org.reactivestreams.Subscription:
cancelrequest
Inherited from reactor.core.Scannable:
actualsfrominnersisScanAvailablenameparentsscanscanOrDefaultstepNamestepstagstagsDeduplicated

Method Detail

actualback to summary
public CoreSubscriber<? super O> actual()
scanUnsafeback to summary
public default 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