Uses of Interface
io.netty.channel.ChannelOutboundBuffer.MessageProcessor
Packages that use ChannelOutboundBuffer.MessageProcessor
Package
Description
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
Optimized transport for linux which uses EPOLL.
Unix specific transport.
io_uring is a high I/O performance scalable interface for fully
asynchronous Linux syscalls.
-
Uses of ChannelOutboundBuffer.MessageProcessor in io.netty.channel
Methods in io.netty.channel with parameters of type ChannelOutboundBuffer.MessageProcessorModifier and TypeMethodDescriptionvoidChannelOutboundBuffer.forEachFlushedMessage(ChannelOutboundBuffer.MessageProcessor processor) CallChannelOutboundBuffer.MessageProcessor.processMessage(Object)for each flushed message in thisChannelOutboundBufferuntilChannelOutboundBuffer.MessageProcessor.processMessage(Object)returnsfalseor there are no more flushed messages to process. -
Uses of ChannelOutboundBuffer.MessageProcessor in io.netty.channel.epoll
Classes in io.netty.channel.epoll that implement ChannelOutboundBuffer.MessageProcessorModifier and TypeClassDescriptionprivate final class -
Uses of ChannelOutboundBuffer.MessageProcessor in io.netty.channel.unix
Classes in io.netty.channel.unix that implement ChannelOutboundBuffer.MessageProcessorModifier and TypeClassDescriptionfinal classRepresent an array of struct array and so can be passed directly over via JNI without the need to do any more array copies. -
Uses of ChannelOutboundBuffer.MessageProcessor in io.netty.channel.uring
Classes in io.netty.channel.uring that implement ChannelOutboundBuffer.MessageProcessorModifier and TypeClassDescriptionprivate final class(package private) final classFills theIoUringIoHandler'sIovArrayfrom flushed outbound messages and records theByteBufbehind each entry it added, so the caller can copy those references into aWriteOperationslot once the SQE is built.Methods in io.netty.channel.uring that return ChannelOutboundBuffer.MessageProcessorModifier and TypeMethodDescriptionprotected ChannelOutboundBuffer.MessageProcessorAbstractIoUringStreamChannel.IoUringStreamUnsafe.filterWriteMultiple(IovArrayReferenceCollector collector) protected ChannelOutboundBuffer.MessageProcessorIoUringSocketChannel.IoUringSocketUnsafe.filterWriteMultiple(IovArrayReferenceCollector collector)