Instance Methodswift-nio 2.72.0NIOCore
fireErrorCaught(_:)
ChannelPipeline.swift:733func fireErrorCaught(_ error: Error)
Other members in extension
Types
enum Position
A
Position
within theChannelPipeline
used to insert handlers into theChannelPipeline
.struct SynchronousOperations
A view of a
ChannelPipeline
which may be used to invoke synchronous operations.
Type members
init(channel: Channel
) Create
ChannelPipeline
for a givenChannel
. This method should never be called by the end-user directly: it is only intended for use with customChannel
implementations. Users should always usechannel.pipeline
to access theChannelPipeline
for aChannel
.
Instance members
var debugDescription: String
let eventLoop: EventLoop
The
EventLoop
that is used by the underlyingChannel
.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 theChannelPipeline
.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: ChannelHandler
) -> EventLoopFuture<ChannelHandlerContext> Returns the
ChannelHandlerContext
that belongs to aChannelHandler
.func context<Handler>(handlerType: Handler.Type
) -> EventLoopFuture<ChannelHandlerContext> Returns the
ChannelHandlerContext
that belongs to aChannelHandler
of the given type.func context(name: String
) -> EventLoopFuture<ChannelHandlerContext> Returns the
ChannelHandlerContext
that belongs to aChannelHandler
.func fireChannelActive(
) func fireChannelInactive(
) func fireChannelRead(NIOAny
) func fireChannelReadComplete(
) func fireChannelRegistered(
) func fireChannelUnregistered(
) func fireChannelWritabilityChanged(
) 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 theChannelPipeline
.func removeHandler(RemovableChannelHandler & Sendable
) async throws func removeHandler(RemovableChannelHandler, promise: EventLoopPromise<Void>?
) Remove a
ChannelHandler
from theChannelPipeline
.func removeHandler(context: ChannelHandlerContext
) -> EventLoopFuture<Void> Remove a
ChannelHandler
from theChannelPipeline
.func removeHandler(context: ChannelHandlerContext
) async throws func removeHandler(context: ChannelHandlerContext, promise: EventLoopPromise<Void>?
) Remove a
ChannelHandler
from theChannelPipeline
.func removeHandler(name: String
) -> EventLoopFuture<Void> Remove a
ChannelHandler
from theChannelPipeline
.func removeHandler(name: String
) async throws func removeHandler(name: String, promise: EventLoopPromise<Void>?
) Remove a
ChannelHandler
from theChannelPipeline
.func triggerUserOutboundEvent(Any, promise: EventLoopPromise<Void>?
) func write(NIOAny, promise: EventLoopPromise<Void>?
) func writeAndFlush(NIOAny, promise: EventLoopPromise<Void>?
)