[akka-user] Re: [akka-stream] Concatenate multiple Sources while preserving materialized values

2016-06-23 Thread Arron Norwell
Sorry, this is actually supported and very straightforward. Solution is: //most common Keep.left case source1.concat(source2) //more general source1.concatMat(source2)(Keep.both) //or whatever strategy On Thursday, June 23, 2016 at 2:55:11 PM UTC-4, Arron Norwell wrote: > > Hi, > >

[akka-user] [akka-stream] Concatenate multiple Sources while preserving materialized values

2016-06-23 Thread Arron Norwell
Hi, I'm looking for a good way to concatenate sources while preserving materialized values. For example, If I have val source1: Source[T,Mat] = _ val source2: Source[T,akka.NotUsed] = _ I would like to be able to preserve the first materialized value (and possibly more generally, support other

[akka-user] Re: [akka-stream] Stream item error propogation and akka-http

2016-04-19 Thread Arron Norwell
both seem to be fairly thin wrappers around the same implementation. This does mean, for better or worse, that all requests would have to have absolute paths. On Tuesday, April 19, 2016 at 11:36:46 AM UTC-4, Arron Norwell wrote: > > Hi, > > I am trying to use akka-http's host-

[akka-user] [akka-stream] Stream item error propogation and akka-http

2016-04-19 Thread Arron Norwell
Hi, I am trying to use akka-http's host-level client-side Http().cachedHostConnectionPool flow as part of a larger stream for which items in the stream may have previously failed, and so it wouldn't make sense to send an HTTP request. In other words, I really want a flow with type something li