Class MessagePeer

Messages are unordered, prioritized individually, and can be given a TTL / marked expired to limit reliability.

Hierarchy

MessagePeer

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new MessagePeer(ackingPeer: AckingPeer, classRegistry: ClassRegistry<Serializable>): MessagePeer

- Defined in network-peer/src/message-peer.ts:250
Parameters
- ackingPeer: AckingPeer
- classRegistry: ClassRegistry<Serializable>
Returns MessagePeer

Properties

Private incomingMessageChannel

incomingMessageChannel: IncomingMessageChannel = ...

onMessageReceived

onMessageReceived: SyncEvent<Serializable> = ...

Private outboundMessageChannel

outboundMessageChannel: OutboundMessageChannel = ...

Methods

flushMessagesToNetwork

flushMessagesToNetwork(): void

- Defined in network-peer/src/message-peer.ts:263
Returns void

sendMessage

sendMessage(message: Serializable, onAck?: () => void): OutboundMessage

- Defined in network-peer/src/message-peer.ts:257
Parameters
- message: Serializable
- Optional onAck: () => void
  - - (): void
    - Returns void
Returns OutboundMessage

Generated using TypeDoc