mirror of
https://github.com/m1k1o/neko-rooms.git
synced 2026-11-02 22:51:34 -06:00
wait only for ready.
This commit is contained in:
@@ -88,8 +88,8 @@ func (p *ProxyManagerCtx) Start() {
|
|||||||
Str("host", host).
|
Str("host", host).
|
||||||
Msg("got room event")
|
Msg("got room event")
|
||||||
|
|
||||||
// terminate waiting for any event
|
// terminate waiting for room ready event
|
||||||
if p.waitEnabled {
|
if p.waitEnabled && msg.Action == types.RoomEventReady {
|
||||||
p.waitMu.Lock()
|
p.waitMu.Lock()
|
||||||
ch, ok := p.waitChans[path]
|
ch, ok := p.waitChans[path]
|
||||||
if ok {
|
if ok {
|
||||||
|
|||||||
Reference in New Issue
Block a user