Tcp::Multiplex::Base

DEMUX_TYPE_MGM = Bytes.new(2, 1)

DEMUX_TYPE_RECV = Bytes.new(1, 0)

DEMUX_TYPE_SEND = Bytes.new(1, 1)

MGM_COMMAND_CLOSE_CLIENT = 58.to_u8

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

close_endp_ch_with_delay(channel : Channel)

data_flow_demux_ch_to_demux_pch_pool(channel : Channel(Bytes))

data_flow_demux_pch_to_demux_sock(socket : TCPSocket, channel : Channel)

data_flow_demux_sock_to_demux_ch(socket : TCPSocket, channel : Channel(Bytes), side_ch : Channel(Bytes))

data_flow_endp_ch_to_endp_sock(socket : TCPSocket, channel : Channel(Bytes))

data_flow_endp_sock_to_endp_ch(socket : TCPSocket, channel : Channel(Bytes), socket_h : Bytes | Nil = nil)

read_management_socket(socket : TCPSocket)