Round robin selector of channels for `fork` api.

[fogfish]

fork.Map assumes that inner function support concurrency. However, one of the fork api purpose is conversion of unsafe code into thread safe.

Let's image we have pool of workers. How to inject the pool into the pipeline?