class Transport
- Transport
- Reference
- Object
Defined in:
wrench/transport.crConstructors
Instance Method Summary
- #add_worker_fiber(fiber : Fiber)
- #alive_interval
- #alive_interval=(value : Time::Span)
- #callback : Proc(Int64, Int64, Nil) | Nil
- #cleanup_all
- #cleanup_side(side : Side, free_tls : Bool)
- #destination : IO
- #destination_tls_context : OpenSSL::SSL::Context::Client?
- #destination_tls_context=(value : OpenSSL::SSL::Context::Client)
- #destination_tls_socket : OpenSSL::SSL::Socket::Client?
- #destination_tls_socket=(value : OpenSSL::SSL::Socket::Client)
- #extra_received_size
- #extra_received_size=(value : Int32 | Int64)
- #extra_sent_size
- #extra_sent_size=(value : Int32 | Int64)
- #finished?
- #free_destination_tls
- #free_source_tls
- #heartbeat : Proc(Nil) | Nil
- #heartbeat_interval
- #heartbeat_interval=(value : Time::Span)
- #mutex : Mutex
- #perform
- #received_size
- #reliable : Reliable
- #reliable=(reliable : Reliable)
- #reliable_status(reliable : Reliable = self.reliable)
- #sent_size
- #source : IO
- #source_tls_context : OpenSSL::SSL::Context::Server?
- #source_tls_context=(value : OpenSSL::SSL::Context::Server)
- #source_tls_socket : OpenSSL::SSL::Socket::Server?
- #source_tls_socket=(value : OpenSSL::SSL::Socket::Server)
- #update_latest_alive
- #workerFibers : Array(Fiber)
Constructor Detail
def self.new(source : IO, destination : IO, callback : Proc(Int64, Int64, Nil) | Nil = nil, heartbeat : Proc(Nil) | Nil = nil)
#