diff options
Diffstat (limited to 'device/channels.go')
| -rw-r--r-- | device/channels.go | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/device/channels.go b/device/channels.go index 1e3e206..bf78868 100644 --- a/device/channels.go +++ b/device/channels.go @@ -87,9 +87,6 @@ func newAutodrainingInboundQueue(device *Device) *autodrainingInboundQueue { for { select { case elem := <-q.c: - if elem == nil { - continue - } elem.Lock() device.PutMessageBuffer(elem.buffer) device.PutInboundElement(elem) @@ -118,9 +115,6 @@ func newAutodrainingOutboundQueue(device *Device) *autodrainingOutboundQueue { for { select { case elem := <-q.c: - if elem == nil { - continue - } elem.Lock() device.PutMessageBuffer(elem.buffer) device.PutOutboundElement(elem) |