Send a write into the ChannelPipeline and flush it right away.
func write(_ data: OutboundOut) async throws This method suspends if the underlying channel is not writable and will resume once the it becomes writable again.
import NIOCoreThe core abstractions that make up SwiftNIO.
struct NIOAsyncChannelOutboundWriter<OutboundOut> where OutboundOut : SendableA NIOAsyncChannelOutboundWriter is used to write and flush new outbound messages in a channel.
final class ChannelPipelineA list of ChannelHandlers that handle or intercept inbound events and outbound operations of a Channel. ChannelPipeline implements an advanced form of the Intercepting Filter pattern to give a user full control over how an event is handled and how the ChannelHandlers in a pipeline interact with each other.
static func makeTestingWriter() -> (Self, TestSink) Creates a new NIOAsyncChannelOutboundWriter backed by a TestSink. This is mostly useful for testing purposes where one wants to observe the written data.
func finish() Finishes the writer.
func write<Writes>(contentsOf sequence: Writes) async throws where OutboundOut == Writes.Element, Writes : Sequence Send a sequence of writes into the ChannelPipeline and flush them right away.
func write<Writes>(contentsOf sequence: Writes) async throws where OutboundOut == Writes.Element, Writes : AsyncSequence Send an asynchronous sequence of writes into the ChannelPipeline.
struct TestSinkAn AsyncSequence backing a NIOAsyncChannelOutboundWriter for testing purposes.