We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6c77c6a commit 53cc7a0Copy full SHA for 53cc7a0
core/utils/zip_channels.go
@@ -4,7 +4,8 @@ package utils
4
import "sync"
5
6
func ZipChannels[T interface{}](channels ...<-chan T) <-chan T {
7
- output := make(chan T)
+ // TODO: Temporary solution must switch to pub-sub
8
+ output := make(chan T, len(channels)*10)
9
wg := new(sync.WaitGroup)
10
for _, ch := range channels {
11
wg.Add(1)
0 commit comments