Send an asynchronous sequence of writes into the ChannelPipeline.
func write<Writes>(contentsOf sequence: Writes) async throws where OutboundOut == Writes.Element, Writes : AsyncSequence s7NIOCore29NIOAsyncChannelOutboundWriterV5write10contentsOfyqd___tYaK7ElementQyd__RszSciRd__lF What are these?9273AThis will flush after every write.
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.
associatedtype Element where Self.Element == Self.AsyncIterator.ElementThe type of element produced by this asynchronous sequence.
protocol AsyncSequence<Element, Failure>A type that provides asynchronous, sequential, iterated access to its elements.
static func makeTestingWriter() -> (NIOAsyncChannelOutboundWriter<OutboundOut>, NIOAsyncChannelOutboundWriter<OutboundOut>.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(_ data: OutboundOut) async throws Send a write into the ChannelPipeline and flush it right away.
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.
struct TestSinkAn AsyncSequence backing a NIOAsyncChannelOutboundWriter for testing purposes.