Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

On Thu, Nov 12, 2015 at 7:09 PM, Simon Schäfer wrote: > > > On 11/12/2015 06:57 PM, Endre Varga wrote: > > Hi Simon, > > This documentation section explains this in more detail: > http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-rate.html > > Ok, I

Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

Hi Simon, This documentation section explains this in more detail: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-rate.html Btw, Sink.head actually does not request more than one, however this is not transitive and cannot be. Grouped cannot possibly know how many

Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

On 11/12/2015 06:57 PM, Endre Varga wrote: Hi Simon, This documentation section explains this in more detail: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-rate.html Ok, I didn't come to that point of the documentation so far. I'm going to have a look,

[akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

I just tried the following (on 2.0-M1): scala> Source(1 to 100).map{i ⇒ println(i); i}.grouped(10).runWith(Sink.head) 1 2 3 4 5 6 7 8 9 10 11 res10: scala.concurrent.Future[scala.collection.immutable.Seq[Int]] = scala.concurrent.impl.Promise$DefaultPromise@2df79942 12 13 14 15 16 scala> 17 18

Re: [akka-user] [akka-stream] demand doesn't follow arguments for for grouped or take

On 11/12/2015 07:15 PM, Endre Varga wrote: On Thu, Nov 12, 2015 at 7:09 PM, Simon Schäfer > wrote: On 11/12/2015 06:57 PM, Endre Varga wrote: Hi Simon, This documentation section explains this in more detail: