add async writes to broadcast
This commit is contained in:
@@ -31,10 +31,10 @@ func (h *hub) run() {
|
||||
for s := range h.sessions {
|
||||
if m.filter != nil {
|
||||
if m.filter(s) {
|
||||
s.writeMessage(m)
|
||||
go s.writeMessage(m)
|
||||
}
|
||||
} else {
|
||||
s.writeMessage(m)
|
||||
go s.writeMessage(m)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -167,7 +167,6 @@ func TestUpgrader(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
func TestBroadcast(t *testing.T) {
|
||||
broadcast := NewTestServer()
|
||||
broadcast.m.HandleMessage(func(session *Session, msg []byte) {
|
||||
@@ -212,7 +211,6 @@ func TestBroadcast(t *testing.T) {
|
||||
t.Error(err)
|
||||
}
|
||||
}
|
||||
*/
|
||||
|
||||
func TestBroadcastOthers(t *testing.T) {
|
||||
broadcast := NewTestServer()
|
||||
|
||||
Reference in New Issue
Block a user