We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0616c5b commit 123b146Copy full SHA for 123b146
queue.go
@@ -643,6 +643,11 @@ func (q *BufferedChannelQueue[T]) GetFreeNodeHookPoolIntervalDuration() time.Dur
643
return q.freeNodeHookPoolIntervalDuration
644
}
645
646
+// GetChannel Get Channel(for Selecting channels usages)
647
+func (q *BufferedChannelQueue[T]) GetChannel() chan T {
648
+ return q.blockingQueue
649
+}
650
+
651
// Count Count items
652
func (q *BufferedChannelQueue[T]) Count() int {
653
if q.isClosed.Get() {
0 commit comments