flatMapPrefixwhich passes in an
Flowwhich accepts a factory of
Collectoralways return a new
factoryis not needed ,but just a collector.
SinkWithContextto akka-streams, most of it is done however I came across a blocker which is I described here https://discuss.lightbend.com/t/concat-partition-doesnt-appear-to-work-when-combining-sinks/9822
S3.getObjectthat has a far more idiomatic API and no longer contains a possible memory leak akka/alpakka#2874