Commit 584d5d84 authored by Cranky Kernel's avatar Cranky Kernel

binance user stream: make queue unbounded

We never want to miss these messages.
parent 0f64fa10
......@@ -206,9 +206,9 @@ Start:
for channel := range b.Subscribers {
select {
case channel <- &streamEvent:
default:
log.Warnf("Failed to send Binance user-stream update to channel [%s]: would block",
b.Subscribers[channel])
//default:
// log.Warnf("Failed to send Binance user-stream update to channel [%s]: would block",
// b.Subscribers[channel])
}
}
b.lock.RUnlock()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment