library/com.pedro.library.multiple/MultiStream

MultiStream

class MultiStream(context: Context, connectCheckerRtmpList: Array<ConnectChecker>?, connectCheckerRtspList: Array<ConnectChecker>?, connectCheckerSrtList: Array<ConnectChecker>?, connectCheckerUdpList: Array<ConnectChecker>?, videoSource: VideoSource, audioSource: AudioSource) : StreamBase

Created by pedro on 17/7/24.

Experiment class.

Support multiple streams in rtmp and rtsp at same time. You must set the same number of ConnectChecker that you want use.

For example. 2 RTMP and 1 RTSP: stream1, stream2, stream3 (stream1 and stream2 are ConnectChecker for RTMP. stream3 is ConnectChecker for RTSP)

MultiStream multiStream = new MultiStream(openGlView, new ConnectChecker[]{ stream1, stream2 }, new ConnectChecker[]{ stream3 });

You can set an empty array or null if you don't want use a protocol new MultiStream(openGlView, new ConnectChecker[]{ stream1, stream2 }, null); //RTSP protocol is not used

In order to use start, stop and other calls you must send type of stream and index to execute it. Example (using previous example interfaces):

multiStream.startStream(MultiType.RTMP, 1, endpoint); //stream2 is started multiStream.stopStream(MultiType.RTSP, 0); //stream3 is stopped multiStream.getStreamClient(MultiType.RTMP, 0).retry(delay, reason, backupUrl) //retry stream1

NOTE: If you call this methods nothing is executed:

multiStream.startStream(endpoint); multiStream.stopStream();

The rest of methods without MultiType and index means that you will execute that command in all streams. Read class code if you need info about any method.

Constructors

MultiStream

constructor(context: Context, connectCheckerRtmpList: Array<ConnectChecker>?, connectCheckerRtspList: Array<ConnectChecker>?, connectCheckerSrtList: Array<ConnectChecker>?, connectCheckerUdpList: Array<ConnectChecker>?)

Properties

audioSource

var audioSource: AudioSource

isOnPreview

var isOnPreview: Boolean

isRecording

val isRecording: Boolean

isStreaming

var isStreaming: Boolean

videoSource

var videoSource: VideoSource

Functions

changeAudioSource

fun changeAudioSource(source: AudioSource)

Change audio source. Must be called after prepareAudio.

changeVideoSource

fun changeVideoSource(source: VideoSource)

Change video source to Camera1 or Camera2. Must be called after prepareVideo.

forceCodecType

fun forceCodecType(codecTypeVideo: CodecUtil.CodecType, codecTypeAudio: CodecUtil.CodecType)

forceFpsLimit

fun forceFpsLimit(enabled: Boolean)

Force stream to work with fps selected in prepareVideo method. Must be called before prepareVideo. This is not recommend because could produce fps problems.

getGlInterface

fun getGlInterface(): GlStreamInterface

Get glInterface used to render video. This is useful to send filters to stream. Must be called after prepareVideo.

getStreamClient

open override fun getStreamClient(): StreamBaseClient

fun getStreamClient(type: MultiType, index: Int): StreamBaseClient

getSurfaceTexture

fun getSurfaceTexture(): SurfaceTexture

return surface texture that can be used to render and encode custom data. Return null if video not prepared. start and stop rendering must be managed by the user.

pauseRecord

fun pauseRecord()

Pause record. Ignored if you are not recording.

prepareAudio

@JvmOverloads

fun prepareAudio(sampleRate: Int, isStereo: Boolean, bitrate: Int, echoCanceler: Boolean = false, noiseSuppressor: Boolean = false): Boolean

Necessary only one time before start stream or record. If you want change values stop stream and record is necessary.

prepareVideo

@JvmOverloads

fun prepareVideo(width: Int, height: Int, bitrate: Int, fps: Int = 30, iFrameInterval: Int = 2, rotation: Int = 0, profile: Int = -1, level: Int = -1): Boolean

Necessary only one time before start preview, stream or record. If you want change values stop preview, stream and record is necessary.

release

fun release()

Stop stream, record and preview and then release all resources. You must call it after finish all the work.

requestKeyframe

fun requestKeyframe()

Force VideoEncoder to produce a keyframe. Ignored if not recording or streaming. This could be ignored depend of the Codec implementation in each device.

resetAudioEncoder

fun resetAudioEncoder(): Boolean

Reset AudioEncoder. Only recommended if an AudioEncoder class error is received in the EncoderErrorCallback

resetVideoEncoder

fun resetVideoEncoder(): Boolean

Reset VideoEncoder. Only recommended if a VideoEncoder class error is received in the EncoderErrorCallback

resumeRecord

fun resumeRecord()

Resume record. Ignored if you are not recording and in pause mode.

setAudioCodec

fun setAudioCodec(codec: AudioCodec)

Change AudioCodec used. This could fail depend of the Codec supported in each Protocol. For example G711 is not supported in SRT

setEncoderErrorCallback

fun setEncoderErrorCallback(encoderErrorCallback: EncoderErrorCallback?)

Set a callback to know errors related with Video/Audio encoders

setFpsListener

fun setFpsListener(callback: FpsListener.Callback?)

setOrientation

fun setOrientation(orientation: Int)

Change stream orientation depend of activity orientation. This method affect to preview and stream. Must be called after prepareVideo.

setRecordController

fun setRecordController(recordController: BaseRecordController)

Replace the current BaseRecordController. This method allow record in other format or even create your custom implementation and record in a new format.

setTimestampMode