stream

Documentation

Overview

Package stream contains the Stream object.

Index

• type Stream
  • func New(udpMaxPayloadSize int, desc *description.Session, generateRTPPackets bool, ...) (*Stream, error)
  • func (s *Stream) AddReader(r *asyncwriter.Writer, medi *description.Media, forma format.Format, ...)
  • func (s *Stream) BytesReceived() uint64
  • func (s *Stream) Close()
  • func (s *Stream) Desc() *description.Session
  • func (s *Stream) RTSPSStream(server *gortsplib.Server) *gortsplib.ServerStream
  • func (s *Stream) RTSPStream(server *gortsplib.Server) *gortsplib.ServerStream
  • func (s *Stream) RemoveReader(r *asyncwriter.Writer)
  • func (s *Stream) WriteRTPPacket(medi *description.Media, forma format.Format, pkt *rtp.Packet, ntp time.Time, ...)
  • func (s *Stream) WriteUnit(medi *description.Media, forma format.Format, u unit.Unit)

Types

type Stream

type Stream struct {
	// contains filtered or unexported fields
}

Stream is a media stream. It stores tracks, readers and allows to write data to readers.

func New

func New(
	udpMaxPayloadSize int,
	desc *description.Session,
	generateRTPPackets bool,
	decodeErrLogger logger.Writer,
) (*Stream, error)

New allocates a Stream.

func (*Stream) AddReader

func (s *Stream) AddReader(r *asyncwriter.Writer, medi *description.Media, forma format.Format, cb readerFunc)

AddReader adds a reader.

func (*Stream) BytesReceived

func (s *Stream) BytesReceived() uint64

BytesReceived returns received bytes.

func (*Stream) Close

func (s *Stream) Close()

Close closes all resources of the stream.

func (*Stream) Desc

func (s *Stream) Desc() *description.Session

Desc returns the description of the stream.

func (*Stream) RTSPSStream

func (s *Stream) RTSPSStream(server *gortsplib.Server) *gortsplib.ServerStream

RTSPSStream returns the RTSPS stream.

func (*Stream) RTSPStream

func (s *Stream) RTSPStream(server *gortsplib.Server) *gortsplib.ServerStream

RTSPStream returns the RTSP stream.

func (*Stream) RemoveReader

func (s *Stream) RemoveReader(r *asyncwriter.Writer)

RemoveReader removes a reader.

func (*Stream) WriteRTPPacket

func (s *Stream) WriteRTPPacket(
	medi *description.Media,
	forma format.Format,
	pkt *rtp.Packet,
	ntp time.Time,
	pts time.Duration,
)

WriteRTPPacket writes a RTP packet.

func (*Stream) WriteUnit

func (s *Stream) WriteUnit(medi *description.Media, forma format.Format, u unit.Unit)

WriteUnit writes a Unit.