Hi there,
that was really great feedback from community! Thank you all for your help.
As far as mapConcat handle Iterable in lazy way I think that is the solution in
my case (I couldn't get it from docs, but akka.stream.impl.fusing.MapConcat
source was really helpful).
This approach beco
+1 for not recommending users to create custom PushPullStages.
Use the simplest tool that gets the job done. :)
On Mon, Nov 23, 2015 at 11:09 AM, Akka Team wrote:
>
>
> On Mon, Nov 23, 2015 at 11:00 AM, Roland Kuhn wrote:
>
>> We shouldn’t need to recommend a custom stage for such a common
>>
On Mon, Nov 23, 2015 at 11:00 AM, Roland Kuhn wrote:
> We shouldn’t need to recommend a custom stage for such a common operation:
>
This is why I mentioned mapConcat first. If that is not enough, there is
PushPullStage.
> doesn’t Source(() => iterator) cover this case completely?
>
No, not ne
We shouldn’t need to recommend a custom stage for such a common operation:
doesn’t Source(() => iterator) cover this case completely? If there is a gap
then we should close it. This approach becomes interestingly powerful when
combined with flatMapConcat—turning each input element into a variabl
Well, "unfold" has completely reasonable use-cases without blocking. For
example a PRNG can be implemented as an unfold. Thankfully, it is easy to
implement these in Akka Streams, either by using mapConcat or creating a
PushPullStage (
http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M
If you need to stream data from an RDBM, use Slick 3, it has support for
Reactive Streams: http://slick.typesafe.com/
On Fri, Nov 20, 2015 at 4:09 PM, Barys Ilyushonak wrote:
> Hi there,
>
> I would like to create a Source, which produce the data from init state
> while it available, and then te
Hi there,
I would like to create a Source, which produce the data from init state
while it available, and then terminates in the end. Something like
play.api.libs.iteratee.Enumerator.unfold, where Option is used to mark that
the value is completely unfolded.
The use case: load data from dat
