Unbounded chan.
Refer to the below articles and issues:
- golang/go#20352
- https://stackoverflow.com/questions/41906146/why-go-channels-limit-the-buffer-size
- https://medium.com/capital-one-tech/building-an-unbounded-channel-in-go-789e175cd2cd
- https://erikwinter.nl/articles/2020/channel-with-infinite-buffer-in-golang/
ch := NewUnboundedChan(1000)
go func() {
...
ch.In <- ... // send values
...
close(ch.In) // close In channel
}()
for v := range ch.Out { // read values
fmt.Println(v)
}