WireMessageRouter
Mongo.WireMessageRouter.swift:8final class WireMessageRouter
Other members in extension
Types
struct NetworkError
enum NetworkErrorProvenance
enum WireAction
class WireMessageParser
struct WireMessageRoutingError
enum WireProtocolError
struct WireTimeoutError
An operation timed out while waiting for a wire response from the server.
Citizens in MongoIO
Conformances
protocol ChannelHandler
Base protocol for handlers that handle I/O events or intercept an I/O operation.
protocol ChannelInboundHandler
ChannelHandler
which handles inbound I/O events for aChannel
.protocol ChannelOutboundHandler
ChannelHandler
which handles outbound I/O events or intercept an outbound I/O operation for aChannel
.protocol Copyable
A type whose values can be implicitly or explicitly copied.
protocol Escapable
Show implementation details (3)
Hide implementation details
protocol _ChannelInboundHandler
Untyped
ChannelHandler
which handles inbound I/O events.protocol _ChannelOutboundHandler
Untyped
ChannelHandler
which handles outbound I/O events or intercept an outbound I/O operation.protocol _EmittingChannelHandler
ChannelHandler which will emit data by calling
ChannelHandlerContext.write
.
Typealiases
Type members
Instance members
func channelInactive(context: ChannelHandlerContext
) func channelRead(context: ChannelHandlerContext, data: NIOAny
) func errorCaught(context: ChannelHandlerContext, error: any Error
) func write(context: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise<Void>?
)
Instance features
func bind(context: ChannelHandlerContext, to: SocketAddress, promise: EventLoopPromise<Void>?
) func channelActive(context: ChannelHandlerContext
) func channelReadComplete(context: ChannelHandlerContext
) func channelRegistered(context: ChannelHandlerContext
) func channelUnregistered(context: ChannelHandlerContext
) func channelWritabilityChanged(context: ChannelHandlerContext
) func close(context: ChannelHandlerContext, mode: CloseMode, promise: EventLoopPromise<Void>?
) func connect(context: ChannelHandlerContext, to: SocketAddress, promise: EventLoopPromise<Void>?
) func flush(context: ChannelHandlerContext
) func handlerAdded(context: ChannelHandlerContext
) Do nothing by default.
func handlerRemoved(context: ChannelHandlerContext
) Do nothing by default.
func read(context: ChannelHandlerContext
) func register(context: ChannelHandlerContext, promise: EventLoopPromise<Void>?
) func triggerUserOutboundEvent(context: ChannelHandlerContext, event: Any, promise: EventLoopPromise<Void>?
) func unwrapInboundIn(NIOAny
) -> InboundIn func unwrapOutboundIn(NIOAny
) -> OutboundIn func userInboundEventTriggered(context: ChannelHandlerContext, event: Any
) func wrapInboundOut(InboundOut
) -> NIOAny func wrapOutboundOut(OutboundOut
) -> NIOAny