Versions in this module Expand all Collapse all v0 v0.0.18 Jul 6, 2022 Changes in this version + type Queue struct + func NewQueue() *Queue + func (self *Queue) Close() (err error) + func (self *Queue) DelayedGopCount(n int) *QueueCursor + func (self *Queue) DelayedTime(dur time.Duration) *QueueCursor + func (self *Queue) Latest() *QueueCursor + func (self *Queue) Oldest() *QueueCursor + func (self *Queue) SetMaxGopCount(n int) + func (self *Queue) WriteHeader(streams []av.CodecData) error + func (self *Queue) WritePacket(pkt av.Packet) (err error) + func (self *Queue) WriteTrailer() error + type QueueCursor struct + func (self *QueueCursor) ReadPacket() (pkt av.Packet, err error) + func (self *QueueCursor) Streams() (streams []av.CodecData, err error)
Go to main page