3 ms·
Generics! func streamingApply[T any](ch channel[T], fn func(T)){ for { select { case <-ctx.Done(): break
by chrsig 3y ago
Generics!
func streamingApply[T any](ch channel[T], fn func(T)){
for {
select {
case <-ctx.Done():
break
case item, ok = <-ch:
if !ok {
break
}
fn(item)
}
}
}
For everyone that's complained about generics being introduced to go...It really does help clean up this type of repetition.