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 3c1f7e4 commit e1577b5Copy full SHA for e1577b5
pkg/core/track.go
@@ -98,16 +98,12 @@ func NewSender(media *Media, codec *Codec) *Sender {
98
}
99
s.Input = func(packet *Packet) {
100
s.mu.Lock()
101
- if s.buf != nil {
102
- // unblocked write to channel
103
- select {
104
- case s.buf <- packet:
105
- s.Bytes += len(packet.Payload)
106
- s.Packets++
107
- default:
108
- s.Drops++
109
- }
110
- } else {
+ // unblock write to nil chan - OK, write to closed chan - panic
+ select {
+ case s.buf <- packet:
+ s.Bytes += len(packet.Payload)
+ s.Packets++
+ default:
111
s.Drops++
112
113
s.mu.Unlock()
0 commit comments