srt/com.haishinkit.srt/SrtStream

SrtStream

class SrtStream(context: Context, val connection: SrtConnection) : Stream

Publishes or plays a single-program MPEG-TS stream over connection. Register this stream as a MediaMixer output for capture, or register a StreamView as this stream's output for playback. Codecs/settings and rendering reuse Stream. Supports H.264/H.265 video and ADTS-framed AAC audio; other codecs are rejected.

The connection must be open before publish or play. One active SrtStream may use a connection at a time. Media jobs belong to the connection's owning scope. close stops media processing while keeping the connection open; dispose additionally releases codec/rendering resources. Close before reconnecting.

Parameters

context

Android context for codecs and rendering.

Constructors

SrtStream

constructor(context: Context, connection: SrtConnection)

Types

ReadyState

enum ReadyState : Enum<SrtStream.ReadyState>

Media-processing state, independent of the connection's handshake state.

Properties

audioSetting

val audioSetting: AudioCodec.Setting

connection

val connection: SrtConnection

Transport connection, owned and closed separately by the caller.

dataSource

open override var dataSource: WeakReference<MediaOutputDataSource>?

expectedMedias

var expectedMedias: Set<MediaType>

Tracks included in the outgoing PMT. Empty derives tracks from the attached mixer. Set before publishing, especially when source formats are not available yet. Reads/assignments use defensive snapshots. Changes while active are rejected.

failure

val failure: StateFlow<Throwable?>

Most recent startup/processing error; reset when a new publish/play begins.

hasAudio

open override var hasAudio: Boolean

hasVideo

open override var hasVideo: Boolean

mediaLink

val mediaLink: MediaLink

readyState

val readyState: StateFlow<SrtStream.ReadyState>

Current media-processing state. Async failures return the stream to IDLE.

screen

open override val screen: Screen

videoSetting

val videoSetting: VideoCodec.Setting

Functions

append

open override fun append(buffer: MediaBuffer)

open override fun close()

Cancels media jobs while retaining the connection. Cleanup releases codecs and the transport claim before readyState returns to ReadyState.IDLE.

dispose

open override fun dispose()

Cancels media and releases rendering resources after job cleanup. Idempotent.

play

suspend fun play()

Starts MPEG-TS reception and codec playback. Returns after the playback pipeline starts; decoders initialize when in-band parameter sets/ADTS configuration arrive. Attach an output view before calling. Subsequent errors are exposed by failure.

publish

suspend fun publish()

Starts encoding and publishing. Suspends until codecs have started, then returns. Subsequent errors are exposed through failure. Queue overflow terminates the stream instead of dropping arbitrary TS packets or retaining unbounded data.

queueOutputBuffer

fun queueOutputBuffer(type: MediaType, index: Int, payload: ByteBuffer?, timestamp: Long, sync: Boolean)

registerOutput

open override fun registerOutput(output: MediaOutput)

unregisterOutput

open override fun unregisterOutput(output: MediaOutput)