| 24 | const DefaultMessageChannelSize = 200 |
| 25 | |
| 26 | type MessageChannel struct { |
| 27 | connectionID livekit.ConnectionID |
| 28 | msgChan chan proto.Message |
| 29 | onClose func() |
| 30 | isClosed bool |
| 31 | lock sync.RWMutex |
| 32 | } |
| 33 | |
| 34 | func NewDefaultMessageChannel(connectionID livekit.ConnectionID) *MessageChannel { |
| 35 | return NewMessageChannel(connectionID, DefaultMessageChannelSize) |
nothing calls this directly
no outgoing calls
no test coverage detected