class Movie::Remote::PendingControlBuffer

• Movie::Remote::PendingControlBuffer
• Reference
• Object

Overview

Connection-owned bounded buffer for system envelopes awaiting ACK.

Defined in:

movie/remote/control_delivery.cr

Constructors

• .new(capacity : Int32)

Instance Method Summary

• #acknowledge(stream : String | Nil, sequence : Int64 | Nil) : Nil
• #clear : Nil
• #offer(envelope : WireEnvelope) : WireEnvelope | Nil
• #pending : Array(WireEnvelope)
• #rebase : Nil
• #size : Int32

Constructor Detail

Instance Method Detail