Constructors
constructor
- new MessageExchange(context, isInitiator, peerSessionId, nodeId, peerNodeId, exchangeId, protocolId): MessageExchange
Properties
Readonly
context
Readonly
isInitiator
isInitiator: boolean
Accessors
channel
- get channel(): MessageChannel
closed
- get closed(): AsyncObservable<[], void>
id
- get id(): number
Returns number
isClosing
- get isClosing(): boolean
Returns boolean
maxPayloadSize
- get maxPayloadSize(): number
Returns number
session
- get session(): Session
Methods
calculateMaximumPeerResponseTime
- calculateMaximumPeerResponseTime(expectedProcessingTimeMs?): number
Parameters
Optional
expectedProcessingTimeMs: number
Returns number
clearTimedInteraction
- clearTimedInteraction(): void
Returns void
close
- close(): Promise<void>
Returns Promise<void>
destroy
- destroy(): Promise<void>
Returns Promise<void>
hasActiveTimedInteraction
- hasActiveTimedInteraction(): boolean
Returns boolean
hasExpiredTimedInteraction
- hasExpiredTimedInteraction(): boolean
Returns boolean
hasTimedInteraction
- hasTimedInteraction(): boolean
Returns boolean
nextMessage
- nextMessage(expectedProcessingTimeMs?): Promise<Message>
Parameters
Optional
expectedProcessingTimeMs: number
Returns Promise<Message>
onMessageReceived
- onMessageReceived(message, isDuplicate?): Promise<void>
Parameters
- message: Message
Optional
isDuplicate: boolean
Returns Promise<void>
send
- send(messageType, payload, options?): Promise<void>
Returns Promise<void>
sendStandaloneAckForMessage
- sendStandaloneAckForMessage(message): Promise<void>
Returns Promise<void>
startTimedInteraction
- startTimedInteraction(timeoutMs): void
Returns void
Static
fromInitialMessage
- fromInitialMessage(context, initialMessage): MessageExchange
Static
initiate
- initiate(context, exchangeId, protocolId): MessageExchange
Max Payload size of the exchange which bases on the maximum payload size of the channel reduced by Matter protocol overhead.