state

Documentation

Overview

Package state controls the source of the RTP packets being written to the stream's subscribers and ensures there is only one active at a time while there are peer connections to receive RTP packets.

Index

• Variables
• type StreamState
  • func New(stream gostream.Stream, r robot.Robot, logger logging.Logger) *StreamState
  • func (state *StreamState) Close() error
  • func (state *StreamState) Decrement() error
  • func (state *StreamState) Increment() error

Variables

var ErrClosed = errors.New("StreamState already closed")

ErrClosed indicates that the StreamState is already closed.

Types

type StreamState

type StreamState struct {
	// Stream is the StreamState's stream
	Stream gostream.Stream
	// contains filtered or unexported fields
}

StreamState controls the source of the RTP packets being written to the stream's subscribers and ensures there is only one active at a time while there are subsribers.

func New

func New(
	stream gostream.Stream,
	r robot.Robot,
	logger logging.Logger,
) *StreamState

New returns a new *StreamState. rtpPassthroughSource is allowed to be nil if the camere does not implement rtppassthrough.Source.

func (*StreamState) Close

func (state *StreamState) Close() error

Close closes the StreamState.

func (*StreamState) Decrement

func (state *StreamState) Decrement() error

Decrement decrements the peer connections subscribed to the stream.

func (*StreamState) Increment

func (state *StreamState) Increment() error

Increment increments the peer connections subscribed to the stream.