/ fm / liveswitch / WssDemuxer

Class: WssDemuxer

fm.liveswitch.WssDemuxer

Hierarchy

• WssDemuxerBase

  ↳ WssDemuxer

Table of contents

Constructors

• constructor

Properties

• __changeRequestReceivers
• __changeRequestReceiversHash
• __changeResponseReceivers
• __changeResponseReceiversHash
• __connectionIds
• __depacketizer
• __keyFrameRequestReceivers
• __keyFrameRequestReceiversHash
• __lock
• __relayPort
• __signallingMessageReceivers
• __signallingMessageReceiversHash
• __stateUpdateReceivers
• __stateUpdateReceiversHash
• _bytesReceivedPerStream
• _messagesReceivedPerStream
• _worker
• _workerString
• fm_liveswitch_WssDemuxerBase___marker

Methods

• addOnConnectionStateUpdate
• addOnEncodedFrameReceived
• addOnKeyFrameRequestReceived
• addOnMediaChangeRequest
• addOnMediaChangeResponse
• addOnSignallingMessage
• bytesReceived
• close
• demux
• getTypeString
• handleEventFromWorker
• messagesReceived
• onReceived
• raiseConnectionStateUpdate
• raiseEncodedFrameReceived
• raiseKeyFrameRequestReceived
• raiseMediaChangeRequest
• raiseMediaChangeResponse
• raiseSignallingMessage
• removeOnConnectionStateUpdate
• removeOnEncodedFrameReceived
• removeOnKeyFrameRequestReceived
• removeOnMediaChangeRequest
• removeOnMediaChangeResponse
• removeOnSignallingMessage
• subscribe
• trackStats
• unsubscribe
• createWorker

Constructors

constructor

+ new WssDemuxer(relayPort: RelayPort, depacketizer: WssDepacketizer): WssDemuxer

Parameters:

Name	Type
relayPort	RelayPort
depacketizer	WssDepacketizer

Returns: WssDemuxer

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:8

Properties

__changeRequestReceivers

• Protected __changeRequestReceivers: ManagedConcurrentDictionary<string, IAction1<WssChangeMediaParametersRequest>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:8

---

__changeRequestReceiversHash

• Protected __changeRequestReceiversHash: ManagedConcurrentDictionary<string, IAction1<WssChangeMediaParametersRequest>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:9

---

__changeResponseReceivers

• Protected __changeResponseReceivers: ManagedConcurrentDictionary<string, IAction1<WssChangeMediaParametersResponse>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:10

---

__changeResponseReceiversHash

• Protected __changeResponseReceiversHash: ManagedConcurrentDictionary<string, IAction1<WssChangeMediaParametersResponse>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:11

---

__connectionIds

• Protected __connectionIds: ManagedConcurrentDictionary<string, Object>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:12

---

__depacketizer

• Protected __depacketizer: WssDepacketizer

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:13

---

__keyFrameRequestReceivers

• Protected __keyFrameRequestReceivers: ManagedConcurrentDictionary<string, IAction0[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:14

---

__keyFrameRequestReceiversHash

• Protected __keyFrameRequestReceiversHash: ManagedConcurrentDictionary<string, IAction0[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:15

---

__lock

• Protected __lock: Object

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:16

---

__relayPort

• Protected __relayPort: RelayPort

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:17

---

__signallingMessageReceivers

• Protected __signallingMessageReceivers: ManagedConcurrentDictionary<string, IAction1<Message>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:18

---

__signallingMessageReceiversHash

• Protected __signallingMessageReceiversHash: ManagedConcurrentDictionary<string, IAction1<Message>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:19

---

__stateUpdateReceivers

• Protected __stateUpdateReceivers: ManagedConcurrentDictionary<string, IAction1<ConnectionState>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:20

---

__stateUpdateReceiversHash

• Protected __stateUpdateReceiversHash: ManagedConcurrentDictionary<string, IAction1<ConnectionState>[]>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:21

---

_bytesReceivedPerStream

• Protected _bytesReceivedPerStream: ManagedConcurrentDictionary<number, AtomicLong>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:22

---

_messagesReceivedPerStream

• Protected _messagesReceivedPerStream: ManagedConcurrentDictionary<number, AtomicLong>

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:23

---

_worker

• Private _worker: Worker

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:4

---

_workerString

▪ Private Static _workerString: string

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:84

---

fm_liveswitch_WssDemuxerBase___marker

▪ Protected Static fm_liveswitch_WssDemuxerBase___marker: Object

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:26

Methods

addOnConnectionStateUpdate

▸ addOnConnectionStateUpdate(connectionId: string, action: IAction1<ConnectionState>): void

Parameters:

Name	Type
connectionId	string
action	IAction1<ConnectionState>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:59

---

addOnEncodedFrameReceived

▸ addOnEncodedFrameReceived(streamId: string, messagePortData: { id: string ; messagePort: MessagePort }): void

Parameters:

Name	Type
streamId	string
messagePortData	object
messagePortData.id	string
messagePortData.messagePort	MessagePort

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:31

---

addOnKeyFrameRequestReceived

▸ addOnKeyFrameRequestReceived(streamId: string, action: IAction0): void

Parameters:

Name	Type
streamId	string
action	IAction0

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:80

---

addOnMediaChangeRequest

▸ addOnMediaChangeRequest(streamId: string, action: IAction1<WssChangeMediaParametersRequest>): void

Parameters:

Name	Type
streamId	string
action	IAction1<WssChangeMediaParametersRequest>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:100

---

addOnMediaChangeResponse

▸ addOnMediaChangeResponse(streamId: string, action: IAction1<WssChangeMediaParametersResponse>): void

Parameters:

Name	Type
streamId	string
action	IAction1<WssChangeMediaParametersResponse>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:120

---

addOnSignallingMessage

▸ addOnSignallingMessage(connectionId: string, action: IAction1<Message>): void

Parameters:

Name	Type
connectionId	string
action	IAction1<Message>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:140

---

bytesReceived

▸ bytesReceived(streamId: number): number

Parameters:

Name	Type
streamId	number

Returns: number

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:160

---

close

▸ close(): void

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:62

---

demux

▸ Privatedemux(binaryMessage: Uint8Array): void

Parameters:

Name	Type
binaryMessage	Uint8Array

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:78

---

getTypeString

▸ getTypeString(): string

Returns: string

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:6

---

handleEventFromWorker

▸ PrivatehandleEventFromWorker(event: any): void

Parameters:

Name	Type
event	any

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:67

---

messagesReceived

▸ messagesReceived(streamId: number): number

Parameters:

Name	Type
streamId	number

Returns: number

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:194

---

onReceived

▸ ProtectedonReceived(receiveArgs: WebSocketReceiveArgs): void

Parameters:

Name	Type
receiveArgs	WebSocketReceiveArgs

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:209

---

raiseConnectionStateUpdate

▸ ProtectedraiseConnectionStateUpdate(connectionId: string, state: ConnectionState): void

Parameters:

Name	Type
connectionId	string
state	ConnectionState

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:248

---

raiseEncodedFrameReceived

▸ ProtectedraiseEncodedFrameReceived(streamId: string, frame: WssMediaPacket): void

Parameters:

Name	Type
streamId	string
frame	WssMediaPacket

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:49

---

raiseKeyFrameRequestReceived

▸ ProtectedraiseKeyFrameRequestReceived(streamId: string): void

Parameters:

Name	Type
streamId	string

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:290

---

raiseMediaChangeRequest

▸ ProtectedraiseMediaChangeRequest(streamId: string, request: WssChangeMediaParametersRequest): void

Parameters:

Name	Type
streamId	string
request	WssChangeMediaParametersRequest

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:325

---

raiseMediaChangeResponse

▸ ProtectedraiseMediaChangeResponse(streamId: string, response: WssChangeMediaParametersResponse): void

Parameters:

Name	Type
streamId	string
response	WssChangeMediaParametersResponse

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:355

---

raiseSignallingMessage

▸ ProtectedraiseSignallingMessage(message: Message): void

Parameters:

Name	Type
message	Message

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:385

---

removeOnConnectionStateUpdate

▸ removeOnConnectionStateUpdate(connectionId: string, action: IAction1<ConnectionState>): void

Parameters:

Name	Type
connectionId	string
action	IAction1<ConnectionState>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:415

---

removeOnEncodedFrameReceived

▸ removeOnEncodedFrameReceived(streamId: string, messagePortId: string): void

Parameters:

Name	Type
streamId	string
messagePortId	string

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:40

---

removeOnKeyFrameRequestReceived

▸ removeOnKeyFrameRequestReceived(streamId: string, action: IAction0): void

Parameters:

Name	Type
streamId	string
action	IAction0

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:434

---

removeOnMediaChangeRequest

▸ removeOnMediaChangeRequest(streamId: string, action: IAction1<WssChangeMediaParametersRequest>): void

Parameters:

Name	Type
streamId	string
action	IAction1<WssChangeMediaParametersRequest>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:453

---

removeOnMediaChangeResponse

▸ removeOnMediaChangeResponse(streamId: string, action: IAction1<WssChangeMediaParametersResponse>): void

Parameters:

Name	Type
streamId	string
action	IAction1<WssChangeMediaParametersResponse>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:472

---

removeOnSignallingMessage

▸ removeOnSignallingMessage(connectionId: string, action: IAction1<Message>): void

Parameters:

Name	Type
connectionId	string
action	IAction1<Message>

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:491

---

subscribe

▸ subscribe(relayPort: RelayPort): void

Parameters:

Name	Type
relayPort	RelayPort

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:14

---

trackStats

▸ ProtectedtrackStats(streamId: number, receiveArgs: WebSocketReceiveArgs): void

Parameters:

Name	Type
streamId	number
receiveArgs	WebSocketReceiveArgs

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxerBase.ts:511

---

unsubscribe

▸ unsubscribe(relayPort: RelayPort): void

Parameters:

Name	Type
relayPort	RelayPort

Returns: void

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:25

---

createWorker

▸ StaticcreateWorker(): Worker

Returns: Worker

Defined in: Generated/TypeScript/fm.liveswitch/WssDemuxer.ts:192