context(handler:)

Other members in extension

Types

• enum Position

  A Position within the ChannelPipeline used to insert handlers into the ChannelPipeline.

• struct SynchronousOperations

  A view of a ChannelPipeline which may be used to invoke synchronous operations.

Type members

• init(channel: Channel)

  Create ChannelPipeline for a given Channel. This method should never be called by the end-user directly: it is only intended for use with custom Channel implementations. Users should always use channel.pipeline to access the ChannelPipeline for a Channel.

Instance members

• var debugDescription: String
• let eventLoop: EventLoop

  The EventLoop that is used by the underlying Channel.

• var syncOperations: SynchronousOperations

  Returns a view of operations which can be performed synchronously on this pipeline. All operations must be called on the event loop.

• func addHandler(ChannelHandler, name: String?, position: ChannelPipeline.Position) -> EventLoopFuture<Void>

  Add a ChannelHandler to the ChannelPipeline.

• func addHandler(ChannelHandler & Sendable, name: String?, position: ChannelPipeline.Position) async throws
• func addHandlers(ChannelHandler..., position: ChannelPipeline.Position) -> EventLoopFuture<Void>

  Adds the provided channel handlers to the pipeline in the order given, taking account of the behaviour of ChannelHandler.add(first:).

• func addHandlers([ChannelHandler], position: ChannelPipeline.Position) -> EventLoopFuture<Void>

  Adds the provided channel handlers to the pipeline in the order given, taking account of the behaviour of ChannelHandler.add(first:).

• func addHandlers((ChannelHandler & Sendable)..., position: ChannelPipeline.Position) async throws
• func addHandlers([ChannelHandler & Sendable], position: ChannelPipeline.Position) async throws
• func bind(to: SocketAddress, promise: EventLoopPromise<Void>?)
• func close(mode: CloseMode, promise: EventLoopPromise<Void>?)
• func connect(to: SocketAddress, promise: EventLoopPromise<Void>?)
• func containsHandler(name: String) -> EventLoopFuture<Void>

  Returns if the ChannelHandler of the given type is contained in the pipeline.

• func containsHandler<Handler>(type: Handler.Type) -> EventLoopFuture<Void>

  Returns if the ChannelHandler of the given type is contained in the pipeline.

• func context<Handler>(handlerType: Handler.Type) -> EventLoopFuture<ChannelHandlerContext>

  Returns the ChannelHandlerContext that belongs to a ChannelHandler of the given type.

• func context(name: String) -> EventLoopFuture<ChannelHandlerContext>

  Returns the ChannelHandlerContext that belongs to a ChannelHandler.

• func fireChannelActive()
• func fireChannelInactive()
• func fireChannelRead(NIOAny)
• func fireChannelReadComplete()
• func fireChannelRegistered()
• func fireChannelUnregistered()
• func fireChannelWritabilityChanged()
• func fireErrorCaught(Error)
• func fireUserInboundEventTriggered(Any)
• func flush()
• func handler<Handler>(type: Handler.Type) -> EventLoopFuture<Handler>

  Returns the first ChannelHandler of the given type.

• func read()
• func register(promise: EventLoopPromise<Void>?)
• func removeHandler(RemovableChannelHandler) -> EventLoopFuture<Void>

  Remove a ChannelHandler from the ChannelPipeline.

• func removeHandler(RemovableChannelHandler & Sendable) async throws
• func removeHandler(RemovableChannelHandler, promise: EventLoopPromise<Void>?)

  Remove a ChannelHandler from the ChannelPipeline.

• func removeHandler(context: ChannelHandlerContext) -> EventLoopFuture<Void>

  Remove a ChannelHandler from the ChannelPipeline.

• func removeHandler(context: ChannelHandlerContext) async throws
• func removeHandler(context: ChannelHandlerContext, promise: EventLoopPromise<Void>?)

  Remove a ChannelHandler from the ChannelPipeline.

• func removeHandler(name: String) -> EventLoopFuture<Void>

  Remove a ChannelHandler from the ChannelPipeline.

• func removeHandler(name: String) async throws
• func removeHandler(name: String, promise: EventLoopPromise<Void>?)

  Remove a ChannelHandler from the ChannelPipeline.

• func triggerUserOutboundEvent(Any, promise: EventLoopPromise<Void>?)
• func write(NIOAny, promise: EventLoopPromise<Void>?)
• func writeAndFlush(NIOAny, promise: EventLoopPromise<Void>?)