pipeline


Description:

public static Channel<U> pipeline<T,U> (Channel<T> input, owned MapFunc<T,U> fn)

Builds a transform pipeline channel.

Parameters:

input

input channel.

fn

transform function.

Returns:

output channel.