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/dist/message-peer.d.ts:33
Parameters
- ackingPeer: AckingPeer
- classRegistry: ClassRegistry<Serializable>
Returns MessagePeer

Properties

Private ackingPeer

ackingPeer: any

Private classRegistry

classRegistry: any

Private incomingMessageChannel

incomingMessageChannel: any

onMessageReceived

onMessageReceived: SyncEvent<Serializable>

Private outboundMessageChannel

outboundMessageChannel: any

Methods

flushMessagesToNetwork

flushMessagesToNetwork(): void

- Defined in network-peer/dist/message-peer.d.ts:37
Returns void

sendMessage

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

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

Generated using TypeDoc