diff --git a/ldk_event_broadcaster.go b/ldk_event_broadcaster.go index cea289b6..be814a5a 100644 --- a/ldk_event_broadcaster.go +++ b/ldk_event_broadcaster.go @@ -42,18 +42,6 @@ func (s *ldkEventBroadcastServer) Subscribe() chan *ldk_node.Event { func (s *ldkEventBroadcastServer) CancelSubscription(channel chan *ldk_node.Event) { close(channel) - // make sure the channel is drained after closing it -out: - for { - select { - case _, ok := <-channel: - if !ok { - break out - } - default: - break out - } - } s.removeListener <- channel }