transport

type BaseInput struct {
	*processor.Base
	// contains filtered or unexported fields
}

type BaseOutput struct {
	*processor.Base
	// contains filtered or unexported fields
}

type InputDriver interface {
	processor.Processor
	// StartReading begins reading media from the transport. It runs under ctx,
	// which is canceled when the transport stops.
	StartReading(ctx context.Context) error
	// StopReading stops reading media from the transport.
	StopReading(ctx context.Context) error
}

type OutputDriver interface {
	processor.Processor
	// WriteAudio sends one chunk of interleaved S16LE PCM over the transport.
	WriteAudio(ctx context.Context, pcm []byte) error
	// SendMessage sends an application message to the client (for example over
	// a data channel).
	SendMessage(ctx context.Context, data []byte) error
}

type Params struct {
	// AudioInEnabled enables receiving audio.
	AudioInEnabled bool
	// AudioInSampleRate is the input sample rate in Hz; 0 uses the StartFrame's.
	AudioInSampleRate int
	// AudioInChannels is the number of input channels.
	AudioInChannels int
	// AudioInPassthrough pushes received audio frames downstream.
	AudioInPassthrough bool

	// AudioOutEnabled enables sending audio.
	AudioOutEnabled bool
	// AudioOutSampleRate is the output sample rate in Hz; 0 uses the StartFrame's.
	AudioOutSampleRate int
	// AudioOutChannels is the number of output channels.
	AudioOutChannels int
	// AudioOutBitrate is the output bitrate in bits per second; 0 uses the
	// codec default.
	AudioOutBitrate int
	// AudioOut10msChunks is how many 10 ms chunks of audio are written at a
	// time. With WebRTC Opus this is 2, so audio is written in 20 ms frames.
	AudioOut10msChunks int
}

type Transport interface {
	// Input returns the processor that emits frames from received media.
	Input() processor.Processor
	// Output returns the processor that sends frames as media.
	Output() processor.Processor
}