Add support for connection handlers
This commit is contained in:
parent
ce8f58ed2d
commit
b38c6b0a54
13
websocket.go
13
websocket.go
@ -59,6 +59,19 @@ func NewWebSocket(baseURL string) (*WSClient, error) {
|
|||||||
return out, nil
|
return out, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// SetConnectHandler sets the connection handler function
|
||||||
|
func (c *WSClient) SetConnectHandler(f func() error) {
|
||||||
|
c.conn.SubscribeHandler = f
|
||||||
|
}
|
||||||
|
|
||||||
|
// ConnectHandler invokes the connection handler function
|
||||||
|
func (c *WSClient) ConnectHandler() error {
|
||||||
|
if c.conn.SubscribeHandler == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return c.conn.SubscribeHandler()
|
||||||
|
}
|
||||||
|
|
||||||
func (c *WSClient) Login(ctx context.Context, l types.Login) error {
|
func (c *WSClient) Login(ctx context.Context, l types.Login) error {
|
||||||
u := &url.URL{}
|
u := &url.URL{}
|
||||||
*u = *c.baseURL
|
*u = *c.baseURL
|
||||||
|
Loading…
Reference in New Issue
Block a user