tyler/rumble-livestream-lib-go
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Check if chat info has been initialized before starting chat stream

Browse source
This commit is contained in:
tyler 2024-04-15 14:58:26 -04:00
parent 1736c64b31
commit 9c99f0d3a6
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
chat.go
View file

@ -281,6 +281,14 @@ func (c *Client) StartChatStream(handle func(cv ChatView), handleError func(err
return pkgErr("", fmt.Errorf("chat stream already started")) return pkgErr("", fmt.Errorf("chat stream already started"))
} }
sseEvent := make(chan *sse.Event) sseEvent := make(chan *sse.Event)
if c.chatInfo == nil {
ci, err := c.getChatInfo()
if err != nil {
return pkgErr("error getting chat info", err)
}
c.chatInfo = ci
}
sseCl := sse.NewClient(c.chatInfo.StreamUrl()) sseCl := sse.NewClient(c.chatInfo.StreamUrl())
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
sseCl.ReconnectStrategy = backoff.WithContext( sseCl.ReconnectStrategy = backoff.WithContext(