class Tcp::Multiplex::Demux

Defined in:

tcp-multiplex-demux.cr

Constructors

Instance Method Summary

Instance methods inherited from class Tcp::Multiplex::Base

close_endp_ch_with_delay(channel : Channel) close_endp_ch_with_delay, data_flow_demux_ch_to_demux_pch_pool(channel : Channel(Bytes)) data_flow_demux_ch_to_demux_pch_pool, data_flow_demux_pch_to_demux_sock(socket : TCPSocket, channel : Channel) data_flow_demux_pch_to_demux_sock, data_flow_demux_sock_to_demux_ch(socket : TCPSocket, channel : Channel(Bytes), side_ch : Channel(Bytes)) data_flow_demux_sock_to_demux_ch, data_flow_endp_ch_to_endp_sock(socket : TCPSocket, channel : Channel(Bytes)) data_flow_endp_ch_to_endp_sock, data_flow_endp_sock_to_endp_ch(socket : TCPSocket, channel : Channel(Bytes), socket_h : Bytes | Nil = nil) data_flow_endp_sock_to_endp_ch, read_management_socket(socket : TCPSocket) read_management_socket

Constructor methods inherited from class Tcp::Multiplex::Base

new(bind_addr : String, bind_ports : String, hop_addr : String, hop_ports : String, fibers : UInt16) new

Instance methods inherited from module Tcp::Multiplex::Helpers

byte_next(value : UInt8) : UInt8 byte_next, bytes_to_u16(slice : Bytes) : UInt16 bytes_to_u16, bytes_to_u32(slice : Bytes) : UInt32 bytes_to_u32, exit_control : Int exit_control, int_to_bytes(int : Int) : Bytes int_to_bytes, md5(slice : Bytes) : String md5, ports_s_to_n(ports : String) : Array(UInt16) ports_s_to_n

Constructor Detail

def self.new(**args) #

[View source]

Instance Method Detail

def data_flow_channel_to_client(channel : Channel(Bytes)) #

[View source]
def run : Int #

[View source]