View on GitHub
SWIMNIOHandler Class Reference
SWIMNIOHandler
public final class SWIMNIOHandler : ChannelDuplexHandlerChannelDuplexHandler responsible for encoding/decoding SWIM messages to/from the SWIMNIOShell.
It is designed to work with DatagramBootstraps, and the contained shell can send messages by writing SWIMNIOSWIMNIOWriteCommand
data into the channel which this handler converts into outbound AddressedEnvelope<ByteBuffer> elements.
-
Declaration
Swift
public typealias InboundIn = AddressedEnvelope<ByteBuffer> -
Declaration
Swift
public typealias InboundOut = SWIM.MemberStatusChangedEvent -
Declaration
Swift
public typealias OutboundIn = SWIMNIOWriteCommand -
Declaration
Swift
public typealias OutboundOut = AddressedEnvelope<ByteBuffer> -
Undocumented
Declaration
Swift
public init(settings: SWIMNIO.Settings) -
Declaration
Swift
public func channelActive(context: ChannelHandlerContext) -
Declaration
Swift
public func channelUnregistered(context: ChannelHandlerContext)
-
Declaration
Swift
public func write(context: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise<Void>?)
-
Declaration
Swift
public func channelRead(context: ChannelHandlerContext, data: NIOAny) -
Declaration
Swift
public func errorCaught(context: ChannelHandlerContext, error: Error)