MCPcopy Index your code
hub / github.com/Monibuca/engine / Stream

Struct Stream

stream.go:193–211  ·  view source on GitHub ↗

Stream 流定义

Source from the content-addressed store, hash-verified

191
192// Stream 流定义
193type Stream struct {
194 timeout *time.Timer //当前状态的超时定时器
195 actionChan util.SafeChan[any]
196 ID uint32 // 流ID
197 *log.Logger
198 StartTime time.Time //创建时间
199 StreamTimeoutConfig
200 Path string
201 Publisher IPublisher
202 publisher *Publisher
203 State StreamState
204 SEHistory []StateEvent // 事件历史
205 Subscribers Subscribers // 订阅者
206 Tracks Tracks
207 AppName string
208 StreamName string
209 IsPause bool // 是否处于暂停状态
210 pubLocker sync.Mutex
211}
212type StreamSummay struct {
213 Path string
214 State StreamState

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected