streammuxer

type OnPacketFunc func(info *StreamInfo, data *StreamData)

type OnStreamCloseFunc func(stream *Stream)

type PullInfo struct {
	Name          string            // 拉流者的名称
	OnPacket      OnPacketFunc      // 数据包回调
	OnStreamClose OnStreamCloseFunc // 拉取的流不可用了
}

type Puller struct {
	PullInfo
	// contains filtered or unexported fields
}

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

type StreamData struct {
	StreamId StreamId
	Data     any
	Addr     net.Addr

	Ntp time.Time
	// contains filtered or unexported fields
}

type StreamId string

type StreamInfo struct {
	Id          StreamId // 必选项
	Name        string
	OnNewPuller func(*Puller) // 新拉流者
	OnDelPuller func(*Puller) // 移除拉流者
}

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

type StreamMuxer interface {
	// AddStream 添加推流stream
	AddStream(info StreamInfo) (*Stream, error)
	RemoteStream(*Stream) error
	GetStream(streamId StreamId) (*Stream, bool)
	RangeStream(fnc func(*Stream) bool)

	// AddPull 添加拉流
	AddPull(streamId StreamId, info PullInfo) (*Puller, error)
	RemotePull(puller *Puller) error

	// Write 发送数据
	Write(data *StreamData) error
	Close()
}