Forgot to allocate done channel
This commit is contained in:
parent
8b92796a5c
commit
e27d917bd4
1 changed files with 1 additions and 0 deletions
|
|
@ -144,6 +144,7 @@ func (b *broker) subscribe(r *http.Request) client {
|
||||||
address: r.RemoteAddr,
|
address: r.RemoteAddr,
|
||||||
userAgent: r.UserAgent(),
|
userAgent: r.UserAgent(),
|
||||||
channel: make(messageChan, 5),
|
channel: make(messageChan, 5),
|
||||||
|
done: make(chan struct{}),
|
||||||
}
|
}
|
||||||
|
|
||||||
// Signal the broker that we have a new client
|
// Signal the broker that we have a new client
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue