move stream close call right after the connect

This commit is contained in:
c9s 2020-07-13 12:20:09 +08:00
parent 704c6eed96
commit 791a745951

View File

@ -33,10 +33,9 @@ func (e *Exchange) QueryAveragePrice(ctx context.Context, symbol string) (float6
return util.MustParseFloat(resp.Price), nil
}
func (e *Exchange) NewPrivateStream(ctx context.Context) (*PrivateStream, error) {
func (e *Exchange) NewPrivateStream() (*PrivateStream, error) {
return &PrivateStream{
Client: e.Client,
// ListenKey: listenKey,
}, nil
}