diff --git a/relaypool.go b/relaypool.go index 8be3487..c0f1892 100644 --- a/relaypool.go +++ b/relaypool.go @@ -272,8 +272,6 @@ func (r *RelayPool) PublishEvent(evt *Event) (*Event, chan PublishStatus, error) } break } - subscription.Unsub() - close(status) }(relay, conn) }