We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5a800b1 commit e899da9Copy full SHA for e899da9
muxer/muxer.go
@@ -160,6 +160,8 @@ func (m *Muxer) RegisterProtocol(
160
m.protocolReceiversMutex.Lock()
161
if _, ok := m.protocolSenders[protocolId]; !ok {
162
m.protocolSenders[protocolId] = make(map[ProtocolRole]chan *Segment)
163
+ }
164
+ if _, ok := m.protocolReceivers[protocolId]; !ok {
165
m.protocolReceivers[protocolId] = make(map[ProtocolRole]chan *Segment)
166
}
167
m.protocolSenders[protocolId][protocolRole] = senderChan
0 commit comments