Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
tcp-multiplex
master
Tcp
Multiplex
Base
Demux
Helpers
Mux
Generated using Crystal 1.14.0
2024-11-26 07:01:58 UTC
class
Tcp::
Multiplex::
Demux
Tcp::Multiplex::Demux
Tcp::Multiplex::Base
Reference
Object
Defined in:
tcp-multiplex-demux.cr
Constructors
.new
(**args)
Instance Method Summary
#data_flow_channel_to_client
(channel : Channel(Bytes))
#run
: Int
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
]