Top Inners Fields Constructors Methods

reactor.netty.channel

pack-priv final Class MonoSendMany<I, O>

Class Inheritance

extends MonoSend<I, O>
implements Scannable

All Implemented Interfaces

reactor.core.Scannable

Imports

java.nio.channels.ClosedChannelException, java.util.AbstractMap, .Map, .Objects, .Queue, java.util.concurrent.TimeUnit, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicReferenceFieldUpdater, java.util.function.BiConsumer, .Consumer, .Function, .Predicate, .ToIntFunction, java.util.stream.Stream, io.netty.buffer.ByteBuf, .ByteBufHolder, io.netty.channel.Channel, .ChannelFuture, .ChannelFutureListener, .ChannelHandlerContext, .ChannelPromise, .DefaultChannelPromise, .EventLoop, io.netty.util.IllegalReferenceCountException, .ReferenceCountUtil, io.netty.util.concurrent.Future, .GenericFutureListener, org.reactivestreams.Publisher, .Subscription, reactor.core.CoreSubscriber, .Exceptions, .Fuseable, .Scannable, reactor.core.publisher.Operators, reactor.util.annotation.Nullable, reactor.util.concurrent.Queues, reactor.util.context.Context

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	MonoSendMany.Completion
pack-priv static class	MonoSendMany.SendManyInner<I, O>

Field Summary

Modifier and Type	Field and Description
pack-priv static final Object	KEY_ON_DISCARD
pack-priv final Predicate<I>	predicate
pack-priv final Publisher<? extends I>	source

Inherited from reactor.netty.channel.MonoSend:: CONSUMER_NOCHECK_CLEANUP ctx MAX_SIZE REFILL_SIZE SIZE_OF SIZE_OF_BB sizeOf sourceCleanup TRANSFORMATION_FUNCTION TRANSFORMATION_FUNCTION_BB transformer

Constructor Summary

Access	Constructor and Description
pack-priv	MonoSendMany(Publisher<? extends I> source, Channel channel, Predicate<I> predicate, Function<? super I, ? extends O> transformer, Consumer<? super I> sourceCleanup, ToIntFunction<O> sizeOf)

Method Summary

Modifier and Type	Method and Description
pack-priv static MonoSendMany<ByteBuf, ByteBuf>	byteBufSource(Publisher<? extends ByteBuf> source, Channel channel, Predicate<ByteBuf> predicate)
pack-priv static <T> void	discardAsyncWithTermination(AtomicIntegerFieldUpdater<T> updater, T instance, Queue<?> q)
pack-priv static <T> void	discardWithTermination(AtomicIntegerFieldUpdater<T> updater, T instance, Queue<?> q, Context context)
pack-priv static MonoSendMany<?, ?>	objectSource(Publisher<?> source, Channel channel, Predicate<Object> predicate)
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 void	subscribe(CoreSubscriber<? super Void> the `Subscriber` interested into the published sequence destination) Implements abstract reactor.core.publisher.Mono.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.
pack-priv static <T> int	wipIncrement(AtomicIntegerFieldUpdater<T> updater, T instance)

Inherited from reactor.netty.channel.MonoSend:: defaultSizeOf