Consider Filter stage

[kalexmills-splunk]

A Filter stage could be useful.

// Filter receives all values from the provided channel and sends only values for which filter(t) is true.
Filter[T any](ctx context.Context, in <-chan T, filter func(T) bool) <-chan T

[kalexmills-splunk]

FYI: This is just syntactic sugar over OptionMap, which itself is syntactic sugar over FlatMap.

i.e. both OptionMap and Filter can be implemented using FlatMap. This only achieves a duplication in code, nothing more.