(i any)
| 144 | } |
| 145 | |
| 146 | func (s *Subscriber) SetIO(i any) { |
| 147 | s.IO.SetIO(i) |
| 148 | if s.Writer != nil && s.Config != nil && s.Config.WriteBufferSize > 0 { |
| 149 | s.Writer = bufio.NewWriterSize(s.Writer, s.Config.WriteBufferSize) |
| 150 | } |
| 151 | } |
| 152 | func (s *Subscriber) OnEvent(event any) { |
| 153 | switch v := event.(type) { |
| 154 | case Track: //默认接受所有track |