class
Matter::Protocol::MessageHandler::PendingSubscription
- Matter::Protocol::MessageHandler::PendingSubscription
- Reference
- Object
Overview
Pending subscription responses - keyed by exchange_id After sending ReportData, we wait for StatusResponse before sending SubscribeResponse Supports chunked responses - remaining_chunks stores chunks yet to be sent
Defined in:
matter/protocol/message_handler.crConstructors
Instance Method Summary
- #attribute_paths : Array(InteractionModel::AttributePath)
- #attribute_paths=(attribute_paths : Array(InteractionModel::AttributePath))
- #max_interval : UInt16
- #max_interval=(max_interval : UInt16)
- #min_interval : UInt16
- #min_interval=(min_interval : UInt16)
- #original_msg : Codec::MessageCodec::Message
- #original_msg=(original_msg : Codec::MessageCodec::Message)
- #peer : Socket::IPAddress
- #peer=(peer : Socket::IPAddress)
- #remaining_chunks : Array(Tuple(Bytes, Bool))
- #remaining_chunks=(remaining_chunks : Array(Tuple(Bytes, Bool)))
- #session : Session::SecureContext
- #session=(session : Session::SecureContext)
- #subscription_id : UInt32
- #subscription_id=(subscription_id : UInt32)
Constructor Detail
def self.new(subscription_id : UInt32, min_interval : UInt16, max_interval : UInt16, peer : Socket::IPAddress, session : Matter::Session::SecureContext, original_msg : Matter::Codec::MessageCodec::Message, attribute_paths : Array(Matter::InteractionModel::AttributePath), remaining_chunks : Array(Tuple(Slice(UInt8), Bool)) = [] of Tuple(Bytes, Bool))
#