Allow flattening collections from a PBegin

[dasch]

Sometimes you want to do this:

  pipeline.begin.transformWith("Something") { _
    .flatten(streamA, streamB, streamC)
    .map(myFn)
  }