Stream 流定义
| 191 | |
| 192 | // Stream 流定义 |
| 193 | type 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 | } |
| 212 | type StreamSummay struct { |
| 213 | Path string |
| 214 | State StreamState |
nothing calls this directly
no outgoing calls
no test coverage detected