提交 d399a932 作者: Juan Batiz-Benet

peer/queue/sync: remove buffering

上级 ec96a0b0
......@@ -23,8 +23,8 @@ func NewChanQueue(ctx context.Context, pq PeerQueue) *ChanQueue {
func (cq *ChanQueue) process(ctx context.Context) {
// construct the channels here to be able to use them bidirectionally
enqChan := make(chan peer.Peer, 10)
deqChan := make(chan peer.Peer, 10)
enqChan := make(chan peer.Peer)
deqChan := make(chan peer.Peer)
cq.EnqChan = enqChan
cq.DeqChan = deqChan
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论