wait when CLOSEing.
This commit is contained in:
@@ -108,7 +108,7 @@ func (sub *Subscription) Close() {
|
|||||||
closeMsg := CloseEnvelope(id)
|
closeMsg := CloseEnvelope(id)
|
||||||
closeb, _ := (&closeMsg).MarshalJSON()
|
closeb, _ := (&closeMsg).MarshalJSON()
|
||||||
debugLog("{%s} sending %v", sub.Relay.URL, closeb)
|
debugLog("{%s} sending %v", sub.Relay.URL, closeb)
|
||||||
sub.Relay.Write(closeb)
|
<-sub.Relay.Write(closeb)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user