class

MeshCoreTCPMux::Broker::Transaction

Inherits Reference < Object

Owns all mutable protocol state and schedules clients onto one companion connection. Runtime delivers socket events here and executes the returned actions; the broker does no I/O.

Constructors

new(owner : Int64, command : Slice(UInt8), descriptor : MeshCoreTCPMux::Protocol::CommandDescriptor, started : Time::Span, pop_sequence : Int64 = 0_i64, notification_generation : Int64 = 0_i64)
Source

Instance methods

command
Source
contacts_started
Source
contacts_started=(contacts_started : Bool)
Source
descriptor
Source
had_multi_client
Source
had_multi_client=(had_multi_client : Bool)
Source
job_id
Source
job_id=(job_id : Int64)
Source
maintenance
Source
maintenance=(maintenance : Bool)
Source
maintenance_write_id
Source
maintenance_write_id=(maintenance_write_id : Int64 | Nil)
Source
notification_generation
Source
owner
Source
pop_sequence
Source
progress
Source
progress=(progress : Time::Span)
Source
response_frames
Source
response_frames=(response_frames : Int32)
Source
scoped
Source
scoped=(scoped : Bool)
Source
started
Source
started=(started : Time::Span)
Source
step
Source
upstream_write_id
Source
upstream_write_id=(upstream_write_id : Int64 | Nil)
Source

Nested types