diff --git a/subscription.go b/subscription.go index 48f86ae..f1826b3 100644 --- a/subscription.go +++ b/subscription.go @@ -108,7 +108,7 @@ func (sub *Subscription) Close() { closeMsg := CloseEnvelope(id) closeb, _ := (&closeMsg).MarshalJSON() debugLog("{%s} sending %v", sub.Relay.URL, closeb) - sub.Relay.Write(closeb) + <-sub.Relay.Write(closeb) } }