ktor-client-webrtc/io.ktor.client.webrtc/WebRtcConnectionEventsEmitter

WebRtcConnectionEventsEmitter

class WebRtcConnectionEventsEmitter(config: WebRtcConnectionConfig) : WebRtcConnectionEvents(source)

Internal implementation of WebRtcConnectionEvents that emits events to flows.

This class maintains the mutable flows and provides methods to emit events from platform-specific WebRTC implementations.

Constructors

constructor(config: WebRtcConnectionConfig)

Properties

dataChannelEvents

open override val dataChannelEvents: SharedFlow<DataChannelEvent>

Flow of newly added connection dataChannels, as a result of the remote peer calling WebRtcPeerConnection.createDataChannel.

iceCandidates

open override val iceCandidates: SharedFlow<WebRtc.IceCandidate>

Flow of ICE candidates generated by this peer connection.

iceConnectionState

open override val iceConnectionState: StateFlow<WebRtc.IceConnectionState>

Flow of ICE connection state changes.

iceGatheringState

open override val iceGatheringState: StateFlow<WebRtc.IceGatheringState>

Flow of ICE gathering state changes.

negotiationNeeded

open override val negotiationNeeded: SharedFlow<Unit>

Sets a callback to be invoked when negotiation (offer-answer exchange, etc.) is needed for this connection.

signalingState

open override val signalingState: StateFlow<WebRtc.SignalingState>

Flow of signaling state changes.

state

open override val state: StateFlow<WebRtc.ConnectionState>

Flow of connection state changes.

stats

open override val stats: StateFlow<List<WebRtc.Stats>>

Flow of connection statistics.

trackEvents

open override val trackEvents: SharedFlow<TrackEvent>

Flow of events on a media track (e.g., add, remove).

Functions

emitAddTrack

fun emitAddTrack(track: WebRtcMedia.Track)

emitConnectionStateChange

fun emitConnectionStateChange(state: WebRtc.ConnectionState)

emitDataChannelEvent

fun emitDataChannelEvent(event: DataChannelEvent)

emitIceCandidate

fun emitIceCandidate(candidate: WebRtc.IceCandidate)

emitIceConnectionStateChange

fun emitIceConnectionStateChange(state: WebRtc.IceConnectionState)

emitIceGatheringStateChange

fun emitIceGatheringStateChange(state: WebRtc.IceGatheringState)

emitNegotiationNeeded

fun emitNegotiationNeeded()

emitRemoveTrack

fun emitRemoveTrack(track: WebRtcMedia.Track)

emitSignalingStateChange

fun emitSignalingStateChange(state: WebRtc.SignalingState)

emitStats

fun emitStats(stats: List<WebRtc.Stats>)