Top Fields Constructors Methods
reactor.netty5.channel

pack-priv abstract Class MonoSend<I, O>

extends Mono<Void>
Class Inheritance
Known Direct Subclasses
reactor.netty5.channel.MonoSendMany
Imports
java.util.Objects, java.util.function.Consumer, .Function, .ToIntFunction, io.netty5.buffer.Buffer, io.netty5.util.Resource, io.netty5.channel.Channel, .ChannelHandlerContext, .FileRegion, reactor.core.publisher.Mono, reactor.netty5.ReactorNetty
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<Buffer>
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<Buffer, Buffer>
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

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<Buffer> 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<Buffer, Buffer> 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)