Akka Streams Preview is Available

[Roland Kuhn]

Dear Scala and Akka community,

we are very excited to unveil what has kept us busy for the past few months: we have collaborated with partners from the industry to draft the Reactive Streams specification, and in order to prove that it works we have created an implementation as well—Akka Streams. For an introduction to the use case, you are welcome to read the official Typesafe announcement, and of course we also have prepared an Activator template with which you can start exploring the API. We currently have only started with the Scala API, you can expect the DSL to grow more feature rich in the coming weeks, and of course Java versions will be forthcoming as well!

The attentive reader will have noted that the source code lives on Akka’s “release-2.3” branch. The intention is to develop it based on the latest stable 2.3.x binary artifact in order to be able to back-release it when it becomes ready. It will of course also be part of Akka 2.4, but that is going to be released only towards the end of the year, see the updated roadmap for more information.

So, for all of you who have been itching to do something like this (or already started) or who just want to play with it: give it a spin, let us know what you think, and if you have suggestions please bring them forward—preferably in pull request form :-)

Regards,

Dr. Roland Kuhn
Akka Tech Lead
Typesafe – Reactive apps on the JVM.
twitter: @rolandkuhn

[Chanan Braunstein]

Thanks Roland, this is looks like exactly what we need to use for mass importing of data from 3 systems into one new one that we will be doing for December - perfect timing! Good to see the collaboration between Typesafe and all the other companies on the reactive streams spec!

[Andrew Charles]

Looks good so far.  I have a quick question though.

The examples all exclusively use futures, but I assume you can use a pure actor implementation as well?  Will there be a sample that uses a more traditional akka actor approach to consume pipelines, etc?

[Alexandru Nedelcu]

On Thu, Apr 17, 2014 at 5:34 PM, Andrew Charles <acha...@gmail.com> wrote:

The examples all exclusively use futures, but I assume you can use a pure actor implementation as well?  Will there be a sample that uses a more traditional akka actor approach to consume pipelines, etc?

AFAIK, the design is not based on Futures. See the interfaces that producers and consumers must implement, as exposed at:

https://github.com/reactive-streams/reactive-streams/tree/master/spi/src/main/java/org/reactivestreams/spi/

--
Alexandru Nedelcu
www.bionicspirit.com

PGP Public Key:
https://bionicspirit.com/key.aexpk

[√iktor Ҡlang]

Akka Streams have an Actor-based FlowMaterializer that uses Actors to power the stream when it materializes.

--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+...@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.

For more options, visit https://groups.google.com/d/optout.

--

Cheers,

√

[Lee Mighdoll]

see the updated roadmap 

statically type-checked actor protocols 

 

Reactive Streams specification based on actors as execution model

Awesome, it's like you've been spying on my secret wish list. Streams that mix with actors, typed actors, woo hoo!

If you start talking about websockets next, I might get really suspicious.

Cheers,

Lee

[Andrew Gaydenko]

On Thursday, April 17, 2014 11:30:22 AM UTC+4, rkuhn wrote:

e also have prepared an Activator template with which you can start exploring the API.

I want more! - TCP streams with custom msg <-> byte buffer encoding/decoding, rechunking in accordance with max length, and so on :)