milarin/channel
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

various optimizations

Browse Source
This commit is contained in:
Timon Ringwald 2022-03-30 15:49:24 +02:00
parent 220f4e6525
commit 55c3c7a464
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chan_io.go
View File

@ -21,9 +21,8 @@ func WriteIntoDelayed[T any](ch chan<- T, delay time.Duration, values ...T) {
// WriteIntoWriter reads all values from ch and writes them via fmt.Fprintln to all writers // WriteIntoWriter reads all values from ch and writes them via fmt.Fprintln to all writers
func WriteIntoWriter[T any](ch <-chan T, writers ...io.Writer) { func WriteIntoWriter[T any](ch <-chan T, writers ...io.Writer) {
for value := range ch { w := io.MultiWriter(writers...)
for _, w := range writers { Each(ch, func(value T) {
fmt.Fprintln(w, value) fmt.Fprintln(w, value)
} })
}
} }

3
timeout.go
View File

@ -3,7 +3,8 @@ package channel
import "time" import "time"
// CloseOnTimeout returns a channel which receives all values from the source. // CloseOnTimeout returns a channel which receives all values from the source.
// If no value was received in the given timeout duration, the returned channel will be closed // If no value was received in the given timeout duration, the returned channel will be closed.
// The input channel will not be closed.
func CloseOnTimeout[T any](source <-chan T, timeout time.Duration) <-chan T { func CloseOnTimeout[T any](source <-chan T, timeout time.Duration) <-chan T {
output := make(chan T, cap(source)) output := make(chan T, cap(source))