(connID livekit.ConnectionID)
| 94 | } |
| 95 | |
| 96 | func NewNullMessageSource(connID livekit.ConnectionID) *NullMessageSource { |
| 97 | return &NullMessageSource{ |
| 98 | connID: connID, |
| 99 | msgChan: make(chan proto.Message), |
| 100 | } |
| 101 | } |
| 102 | |
| 103 | func (n *NullMessageSource) ReadChan() <-chan proto.Message { |
| 104 | return n.msgChan |