diff --git a/relay.go b/relay.go index b1c4cfb..a88dde5 100644 --- a/relay.go +++ b/relay.go @@ -474,7 +474,7 @@ func (r *Relay) WriteWithError(msg []byte) error { defer r.closeMutex.Unlock() - if r.writeQueue != nil { + if r.writeQueue == nil { return nil }