We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0718148 commit e107f99Copy full SHA for e107f99
provider/internal/queue/queue.go
@@ -51,7 +51,6 @@ func NewQueue(ds datastore.Datastore) *Queue {
51
q := &Queue{
52
ds: namespace.Wrap(ds, datastore.NewKey("/queue")),
53
dequeue: make(chan cid.Cid),
54
- //enqueue: make(chan cid.Cid, 1024),
55
enqueue: chanqueue.New(chanqueue.WithCapacity[cid.Cid](inputBufferSize)),
56
close: cancel,
57
closed: make(chan struct{}),
0 commit comments