Improve channel type hint
This commit is contained in:
parent
7a09569c03
commit
d303f551f3
1 changed files with 2 additions and 2 deletions
|
@ -106,7 +106,7 @@ func Compact[T any](a []T, compactor func(acc T, next T) T) T {
|
|||
// Returns a channel that all elements in a will be written to in order.
|
||||
// Once all values of a have been sent, the channel will be closed.
|
||||
// The channel must be fully consumed until closed. Otherwise a goroutine will be leaked
|
||||
func ToChannel[T any](a []T) chan T {
|
||||
func ToChannel[T any](a []T) <-chan T {
|
||||
c := make(chan T)
|
||||
go func() {
|
||||
for _, v := range a {
|
||||
|
@ -120,7 +120,7 @@ func ToChannel[T any](a []T) chan T {
|
|||
|
||||
// FromChannel reads from a channel until closed, appending every element to a slice.
|
||||
// If you do not know how many elements to expect, use an expectedSize of 0
|
||||
func FromChannel[T any](c chan T, expectedSize uint) []T {
|
||||
func FromChannel[T any](c <-chan T, expectedSize uint) []T {
|
||||
a := make([]T, expectedSize)
|
||||
for v := range c {
|
||||
a = append(a, v)
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue