Top Description Fields Constructors Methods
reactor.netty.channel

pack-priv abstract Class MonoSend<I, O>

extends Mono<Void>
Class Inheritance
Known Direct Subclasses
reactor.netty.channel.MonoSendMany
Imports
java.util.Objects, java.util.function.Consumer, .Function, .ToIntFunction, io.netty.buffer.ByteBuf, .ByteBufHolder, io.netty.channel.Channel, .ChannelHandlerContext, .FileRegion, io.netty.util.ReferenceCountUtil, reactor.core.publisher.Mono, reactor.netty.ReactorNetty
An outbound-traffic API delegating to an underlying Channel.
Author
Stephane Maldini

Field Summary

Modifier and TypeField and Description
pack-priv static final Consumer<Object>
CONSUMER_NOCHECK_CLEANUP

pack-priv final ChannelHandlerContext
ctx

pack-priv static final int
MAX_SIZE

pack-priv static final int
REFILL_SIZE

pack-priv static final ToIntFunction<Object>
SIZE_OF

pack-priv static final ToIntFunction<ByteBuf>
SIZE_OF_BB

pack-priv final ToIntFunction<? super O>
sizeOf

pack-priv final Consumer<? super I>
sourceCleanup

pack-priv static final Function<Object, Object>
TRANSFORMATION_FUNCTION

pack-priv static final Function<ByteBuf, ByteBuf>
TRANSFORMATION_FUNCTION_BB

pack-priv final Function<? super I, ? extends O>
transformer

Constructor Summary

AccessConstructor and Description
pack-priv
MonoSend(Channel channel, Function<? super I, ? extends O> transformer, Consumer<? super I> sourceCleanup, ToIntFunction<? super O> sizeOf)

Method Summary

Modifier and TypeMethod and Description
pack-priv static <O> ToIntFunction<O>
defaultSizeOf()

Inherited from reactor.core.publisher.Mono:
andasblockblockblockOptionalblockOptionalcachecachecachecachecachecacheInvalidateIfcacheInvalidateWhencacheInvalidateWhencancelOncastcheckpointcheckpointcheckpointconcatWithcontextCapturecontextWritecontextWritecreatedefaultIfEmptydeferdeferContextualdelaydelaydelayElementdelayElementdelaySubscriptiondelaySubscriptiondelaySubscriptiondelayUntildematerializedoAfterTerminatedoFinallydoFirstdoOnCanceldoOnDiscarddoOnEachdoOnErrordoOnErrordoOnErrordoOnNextdoOnRequestdoOnSubscribedoOnSuccessdoOnTerminateelapsedelapsedemptyerrorerrorexpandexpandexpandDeepexpandDeepfilterfilterWhenfirstfirstfirstWithSignalfirstWithSignalfirstWithValuefirstWithValueflatMapflatMapIterableflatMapManyflatMapManyfluxfromfromCallablefromCompletionStagefromCompletionStagefromDirectfromFuturefromFuturefromFuturefromFuturefromRunnablefromSupplierhandlehasElementhideignoreElementignoreElementsjustjustOrEmptyjustOrEmptyloglogloglogloglogmapmapNotNullmaterializemergeWithmetricsnameneverofTypeonAssemblyonErrorCompleteonErrorCompleteonErrorCompleteonErrorContinueonErrorContinueonErrorContinueonErrorMaponErrorMaponErrorMaponErrorResumeonErrorResumeonErrorResumeonErrorReturnonErrorReturnonErrorReturnonErrorStoponTerminateDetachorpublishpublishOnrepeatrepeatrepeatrepeatrepeatWhenrepeatWhenEmptyrepeatWhenEmptyretryretryretryWhensequenceEqualsequenceEqualsequenceEqualsharesinglesingleOptionalsubscribesubscribesubscribesubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeWithswitchIfEmptytagtaketaketakeUntilOthertaptaptapthenthenthenEmptythenManythenReturntimedtimedtimeouttimeouttimeouttimeouttimeouttimeouttimestamptimestamptoFuturetoStringtransformtransformDeferredtransformDeferredContextualusingusingusingWhenusingWhenwhenwhenwhenDelayErrorwhenDelayErrorzipzipzipzipzipzipzipzipzipzipzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipWhenzipWhenzipWithzipWith

Field Detail

CONSUMER_NOCHECK_CLEANUPback to summary
pack-priv static final Consumer<Object> CONSUMER_NOCHECK_CLEANUP
ctxback to summary
pack-priv final ChannelHandlerContext ctx
MAX_SIZEback to summary
pack-priv static final int MAX_SIZE
REFILL_SIZEback to summary
pack-priv static final int REFILL_SIZE
SIZE_OFback to summary
pack-priv static final ToIntFunction<Object> SIZE_OF
SIZE_OF_BBback to summary
pack-priv static final ToIntFunction<ByteBuf> SIZE_OF_BB
sizeOfback to summary
pack-priv final ToIntFunction<? super O> sizeOf
sourceCleanupback to summary
pack-priv final Consumer<? super I> sourceCleanup
TRANSFORMATION_FUNCTIONback to summary
pack-priv static final Function<Object, Object> TRANSFORMATION_FUNCTION
TRANSFORMATION_FUNCTION_BBback to summary
pack-priv static final Function<ByteBuf, ByteBuf> TRANSFORMATION_FUNCTION_BB
transformerback to summary
pack-priv final Function<? super I, ? extends O> transformer

Constructor Detail

MonoSendback to summary
pack-priv MonoSend(Channel channel, Function<? super I, ? extends O> transformer, Consumer<? super I> sourceCleanup, ToIntFunction<? super O> sizeOf)

Method Detail

defaultSizeOfback to summary
pack-priv static <O> ToIntFunction<O> defaultSizeOf()
Annotations
@SuppressWarnings:unchecked