this is excellent feedback,
I think there's room for improvement for grokkability of Akka Streams,
thanks Derek and Endre.
--
Cheers,
√
On 1 Aug 2015 13:12, "Derek Wyatt" wrote:
>
> Endre Varga
> July 31, 2015 at 4:47 AM
>
>
> On Thu, Jul 30, 2015 at 9:07 PM, Derek Wyatt wrote:
>
>>
>>
>> End
Hi Derek,
On Thu, Jul 30, 2015 at 6:48 PM, Derek Wyatt wrote:
> These examples, and the new documentation page, are extremely helpful.
> Thank you *very* much. I’m continuing to read / digest / modify them to
> get a better understanding, but they’ve already cleared up a lot for me.
>
> One thin
These examples, and the new documentation page, are extremely helpful.
Thank you /very/ much. I’m continuing to read / digest / modify them to
get a better understanding, but they’ve already cleared up a lot for me.
One thing that popped out was the use of |Flow.transform()|. The
difference be
Hey Endre,
Thanks so much for doing this. I've looked through it (and skimmed the
new doc page) but haven't digested it well enough to say anything other
than "thanks". :) I'll get back to you in the next day or so, perhaps
with a couple of questions.
Akka Team wrote:
And now I added anoth
And now I added another version where the server just streams random
numbers until the client disconnects, then it closes the connection. It
needed a custom stage though to make emitting from an Iterable
interruptible (mapConcat does not interrupt on completion, only on errors).
On Wed, Jul 29, 20
I now updated the gist with the reverse direction: Now a client sends a
String command and expects an Iterable[Int] back as a response. I currently
limited the funcionality to one request per connection, since otherwise I
would need a bit more elaborate codec which would complicate the example (I
w
Hi Derek,
It is not that hard, but you need to develop a certain kind of intuition to
attack these problems. I very much recommend the new documentation page
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/stream-composition.html
as it helps to visualize the ideas.
I created a
Hi,
I'm still trying to figure out the best way to work with TCP flows and,
while I've got something working, this seems really quite wrong, so there's
gotta be a better way.
What I want to do is send an Iterable[Int] from the client to the server
and have the server materialize that resulting
