class

Transfer

Inherits Reference < Object

Constructors

new(source : IO, destination : IO, finishCallback : Proc(Transfer, UInt64, UInt64, Nil) | Nil = nil, heartbeatCallback : Proc(Transfer, Time::Span, Bool) | Nil = nil)
Source

Instance methods

aliveInterval
Source
aliveInterval=(aliveInterval : Time::Span)
Source
any_done?
Source
check_exceed_threshold?(any_side_bytes_exceed : Bool) : Bool
Source
close(sd_flag : SDFlag)
Source
close
Source
concurrentFibers
Source
concurrentMutex
Source
destination
Source
destination=(destination : IO)
Source
exceedThresholdFlag
Source
exceedThresholdFlag=(exceedThresholdFlag : Atomic(ExceedThresholdFlag))
Source
finishCallback
Source
finishCallback=(finishCallback : Proc(Transfer, UInt64, UInt64, Nil) | Nil)
Source
finished?
Source
first_alive_time
Source
firstAliveTime
Source
heartbeat_counter
Source
heartbeatCallback
Source
heartbeatCallback=(heartbeatCallback : Proc(Transfer, Time::Span, Bool) | Nil)
Source
heartbeatCounter
Source
heartbeatInterval
Source
heartbeatInterval=(heartbeatInterval : Time::Span)
Source
last_alive_time
Source
lastAliveTime
Source
mutex
Source
perform
Source
receive_done?
Source
receive_exception=(value : Exception | Nil)
Source
receive_exception?
Source
received_bytes
Source
receivedBytes
Source
receiveDone
Source
sent_bytes
Source
sent_done?
Source
sent_exception=(value : Exception | Nil)
Source
sent_exception?
Source
sentBytes
Source
sentDone
Source
socketSwitchBytes
Source
socketSwitchBytes=(socketSwitchBytes : Atomic(UInt64))
Source
socketSwitchExpression
Source
socketSwitchExpression=(socketSwitchExpression : Atomic(SocketSwitchExpressionFlag))
Source
socketSwitchSeconds
Source
socketSwitchSeconds=(socketSwitchSeconds : Atomic(UInt64))
Source
source
Source
source=(source : IO)
Source
strict_check_receive_exceed_threshold?
Source
strict_check_sent_exceed_threshold?
Source

Nested types