[akka-user] Re: Akka Stream: How to dynamically group elements?

2015-02-02 Thread Elmar Weber
Hi.

thanks for the quick reply, that's exactly what I was looking for.

ciao,
elm

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


[akka-user] new project - akka streams/http - is using the current spray release with akka streams and migrating later too painful?

2015-02-02 Thread Giovanni Alberto Caporaletti
Hi,
I need to start a new project in a couple of months (and hopefully have a 
first working prototype in 2-3 months more). I am a rxscala/java user, and 
am following the reactive streams/akka streams projects with huge interest.

For the api layer, akka-http is too immature to be used right now (I need 
websockets and ssl for example), although I'd really like to use the new 
akka streams api for the reactive logic. Do you think it makes sense/is 
possible to use the latest release of spray and integrate it with the 
current milestone of akka-streams only to migrate everything to akka-http 
later on? If not, what do you suggest? *When do you think akka streams/http 
1.0 final will be released?*

Alternatively, do you think it would be a good choice to start with rxscala 
(maybe using the reactive streams adapters, but I've never used them) and 
then migrate to akka streams?


Thanks
G

TL;DR: I've been using rxscala for another project, I really want to use 
akka streams for a new one but need ssl, websocket and implementation 
maturity of spray. What do I do?


-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


[akka-user] Re: Using different names for application.conf

2015-02-02 Thread Adam
See here: http://doc.akka.io/docs/akka/snapshot/general/configuration.html

You can add the system property -Dconfig.resource=
And load whatever file you wish as your configuration file.

On Monday, February 2, 2015 at 8:55:13 PM UTC+2, Mark Kaberman wrote:
>
> My application consists out of multiple services (daemons) which 
> unfortunately have to share the location for configuration files. I would 
> prefer to avoid maintaining single application.conf which is shared by all 
> services due to logistical reasons. I also cannot package individual 
> application.conf in the jars since I would like to have the ability to 
> tweak my configuration on the fly (changing number of actor's instances). 
> So my question is if it is possible to use different names for 
> configuration files instead of application.conf? This will allow each 
> service to have own configuration which can share at the same location.
>
> Thanks,
>
> Mark
>
>

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


[akka-user] Using different names for application.conf

2015-02-02 Thread Mark Kaberman
My application consists out of multiple services (daemons) which 
unfortunately have to share the location for configuration files. I would 
prefer to avoid maintaining single application.conf which is shared by all 
services due to logistical reasons. I also cannot package individual 
application.conf in the jars since I would like to have the ability to 
tweak my configuration on the fly (changing number of actor's instances). 
So my question is if it is possible to use different names for 
configuration files instead of application.conf? This will allow each 
service to have own configuration which can share at the same location.

Thanks,

Mark

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


Re: [akka-user] Akka Stream: How to dynamically group elements?

2015-02-02 Thread Endre Varga
On Mon, Feb 2, 2015 at 6:49 PM, Akka Team  wrote:

> Hi Elmar,
>
>
>
> On Mon, Feb 2, 2015 at 6:40 PM, Elmar Weber  wrote:
>
>> I am looking to batch elements in a flow in a non-standard way and
>> sending them off.
>> A typical flow for this based on a static count would look like this:
>>
>> Source[Element]
>>   .grouped(batchSize)
>>   .map(doRest(elements)
>>   .Sink[LogResultsSomewhere]
>>
>> Now, instead of a batchSize I want a different way to group the elements,
>> e.g. by size in bytes or by a dynamic batch size values that adjust to an
>> external condition.
>>
>> My current solution for this is to use fold (scan) with filter. The fold
>> function returns an option of the batched result, when the batch limit is
>> reached it becomes Some(batch) and then the next element, a filter, only
>> let's the batched elements pass through.
>> An example is at https://gist.github.com/elm-/316236f63dce4feca34f
>> (never mind the Await)
>>
>> While this works, there are two issues:
>> - looks too complicated
>> - no final flush, i.e. the last batch lost since I do not know when to
>> trigger my manual batch in the scan, i.e. check when it is the last element
>>
>> My question is, is there a way to get this done with the standard methods
>> and or what solution would be best here?
>>
>
> The solution is to use a custom stage, described here:
>
>
> http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-customize.html
>
> There are various examples in the cookbook how to use custom stages:
>
>
> http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-cookbook.html
>

btw, internally grouped is also implemented as a stage:

https://github.com/akka/akka/blob/release-2.3-dev/akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala#L130


>
>
> -Endre
>
>
>>
>> What I have in mind is to provide a custom grouped() implementation that
>> takes my own condition.
>>
>> --
>> >> 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+unsubscr...@googlegroups.com.
>> To post to this group, send email to akka-user@googlegroups.com.
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> --
> Akka Team
> Typesafe - The software stack for applications that scale
> Blog: letitcrash.com
> Twitter: @akkateam
>
> --
> >> 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+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


Re: [akka-user] Akka Stream: How to dynamically group elements?

2015-02-02 Thread Akka Team
Hi Elmar,



On Mon, Feb 2, 2015 at 6:40 PM, Elmar Weber  wrote:

> I am looking to batch elements in a flow in a non-standard way and sending
> them off.
> A typical flow for this based on a static count would look like this:
>
> Source[Element]
>   .grouped(batchSize)
>   .map(doRest(elements)
>   .Sink[LogResultsSomewhere]
>
> Now, instead of a batchSize I want a different way to group the elements,
> e.g. by size in bytes or by a dynamic batch size values that adjust to an
> external condition.
>
> My current solution for this is to use fold (scan) with filter. The fold
> function returns an option of the batched result, when the batch limit is
> reached it becomes Some(batch) and then the next element, a filter, only
> let's the batched elements pass through.
> An example is at https://gist.github.com/elm-/316236f63dce4feca34f (never
> mind the Await)
>
> While this works, there are two issues:
> - looks too complicated
> - no final flush, i.e. the last batch lost since I do not know when to
> trigger my manual batch in the scan, i.e. check when it is the last element
>
> My question is, is there a way to get this done with the standard methods
> and or what solution would be best here?
>

The solution is to use a custom stage, described here:

http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-customize.html

There are various examples in the cookbook how to use custom stages:

http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-cookbook.html

-Endre


>
> What I have in mind is to provide a custom grouped() implementation that
> takes my own condition.
>
> --
> >> 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+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>



-- 
Akka Team
Typesafe - The software stack for applications that scale
Blog: letitcrash.com
Twitter: @akkateam

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


[akka-user] Akka Stream: How to dynamically group elements?

2015-02-02 Thread Elmar Weber
I am looking to batch elements in a flow in a non-standard way and sending 
them off.
A typical flow for this based on a static count would look like this:

Source[Element]
  .grouped(batchSize)
  .map(doRest(elements)
  .Sink[LogResultsSomewhere]

Now, instead of a batchSize I want a different way to group the elements, 
e.g. by size in bytes or by a dynamic batch size values that adjust to an 
external condition.

My current solution for this is to use fold (scan) with filter. The fold 
function returns an option of the batched result, when the batch limit is 
reached it becomes Some(batch) and then the next element, a filter, only 
let's the batched elements pass through.
An example is at https://gist.github.com/elm-/316236f63dce4feca34f (never 
mind the Await)

While this works, there are two issues:
- looks too complicated
- no final flush, i.e. the last batch lost since I do not know when to 
trigger my manual batch in the scan, i.e. check when it is the last element

My question is, is there a way to get this done with the standard methods 
and or what solution would be best here?

What I have in mind is to provide a custom grouped() implementation that 
takes my own condition.

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


Re: [akka-user] tcp client server recommendations

2015-02-02 Thread Peter Swift
Hey that's pretty nifty! In the meantime, Jeremy's silent actor publisher 
is working well.

Thanks,
Peter

On Monday, February 2, 2015 at 1:30:57 AM UTC-8, drewhk wrote:
>
>
>
> On Sun, Feb 1, 2015 at 9:05 PM, Jeremy Stone  > wrote:
>
>> Would something like the following in the server handler do it for you?...
>>
>> def silentSource = ??? // Source that emits nothing but does never 
>> completes
>> def handleDataFromClient: ByteString => Unit = ??? 
>>
>> ForeachSink[StreamTcp.IncomingConnection] { conn =>
>>   println("Client connected from: " + conn.remoteAddress)
>>
>>   silentSource.via(conn.flow).to(Sink.foreach(handleDataFromClient)).
>> run
>> }
>>
>> AFAIK there is no silent, non-completing Source implementation shipped 
>> with the akka streams library (1.0-M2).
>>
>
> Now there is: https://github.com/akka/akka/pull/16750
>
> Will be available in M3.
>
> -Endre
>  
>
>>  We had a similar situation and had to create one using a very simple 
>> ActorPublisher. Alternatively, maybe first try it using a TickSource with a 
>> long initial delay.
>>
>> -- 
>> >> 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.
>>
>
>

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


Re: [akka-user] Relation between Number of cores & number of actors

2015-02-02 Thread Akka Team
Hi Samya,

On Sun, Feb 1, 2015 at 9:43 AM, Samya Maiti 
wrote:

> Hi Team,
>
> I have a small akka application which works fine, processes some thousand
> messages per second.
>
> But I am curious to Know :
> 1.  How is number of cores of a system related to number of actors?
>

There is no such relation, you are free to create as many actors as you
want.

>
> 2. How is the upper limit of the number of actors determined was say a 8
> cores system?
>

There is no upper limit, you are free to create as many actors as you need.
The actors' execution is multiplexed over a thread pool (the so-called
dispatcher). You can set the number of streams in the dispatchers, see this
doc section: http://doc.akka.io/docs/akka/2.3.9/scala/dispatchers.html


>
> 3. Also is it true to say, at an instance of time maximum actors that can
> be in action = number of cores?
>

I do not understand this question. How can physically any more
computational entities be active than the number of actual cores?

-Endre


>
> Regards,
> Sam
>
> --
> >> 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+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>



-- 
Akka Team
Typesafe - The software stack for applications that scale
Blog: letitcrash.com
Twitter: @akkateam

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


[akka-user] Re: Send message from netty code to actor system

2015-02-02 Thread Ngoc Dao
You can try Xitrum web framework (scroll down to see the Akka actor 
example):
http://xitrum-framework.github.io/


On Tuesday, January 27, 2015 at 6:29:43 PM UTC+9, Jabbar Azam wrote:
>
> Hello,
>
> How do I send a message from java non actor based code into an actor 
> system? The code will be running on the same node and will be part of the 
> same source code. So netty will be running, receiving packets, which will 
> send any received packets into an actor system. The actor system will 
> process the packets and then send the response payload back to the netty 
> code.
>
>
>

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


Re: [akka-user] Re: Implementing at-least-once ingestion pipeline with Akka streams

2015-02-02 Thread Endre Varga
Hi Evan,

As we progress we make more and more things possible, we will keep this
use-case in mind.

-Endre

On Sat, Jan 31, 2015 at 2:52 AM, Evan Chan  wrote:

> Thanks Bjorn.
>
> On Fri, Jan 30, 2015 at 2:33 AM, Björn Antonsson <
> bjorn.antons...@typesafe.com> wrote:
>
>> Hi Evan,
>>
>> I don't think that it's easily possible to feed back things into a Source
>> right now. You would need a special kind of Source with an input port as
>> well to wire it up properly in the Graph. The only solution that I can
>> think of at the moment is to have a PropsSource and a PropsSink that
>> materialize into actors, and then you "connect" them on the side by sending
>> normal actor messages.
>>
>> B/
>>
>> On 27 January 2015 at 17:08:59, Evan Chan (vel...@gmail.com) wrote:
>>
>> I got feedback from @ktosopl that you can send feedback in a graph back
>> to a Source.  Does anyone have an example of this?
>>
>> Thanks!
>>
>> On Tue, Jan 27, 2015 at 8:07 AM, Evan Chan  wrote:
>>
>>>  Thanks.  I know you can form graphs, but doing a custom merge is not
>>> quite what I'm looking for.
>>>
>>> I need to change the state of a Source, using feedback from a Sink.
>>>
>>> Example: Kafka source. Depending on Sink output / acknowledgements,
>>> reset Kafka offset to an earlier offset.
>>>
>>> This can't be done by filtering, delaying, etc. the Kafka input source
>>> via another processing unit.  This requires changing the state of the
>>> Source to begin with, or sending a message to it (if it were Actor-based).
>>>
>>> Another example: let's say you have an HTTP-based source.  Depending on
>>> the acknowledgements, we need to give a proper response code: 200, 500, etc.
>>>
>>> On Wed, Jan 21, 2015 at 10:36 AM, Martynas Mickevičius <
>>> martynas.mickevic...@typesafe.com> wrote:
>>>
 Just an idea: you can actually form cycles
 
  in
 the Flow graph, which you can use to feedback acknowledgments.

 On Sun, Jan 18, 2015 at 2:18 AM, Evan Chan  wrote:

> Ping anybody?
>
>
> On Thursday, January 15, 2015 at 4:59:19 PM UTC-8, Evan Chan wrote:
>>
>> Hey folks,
>>
>> I would like to implement an at-least-once ingestion pipeline, say
>> from a source like Kafka, to a datastore, using Akka streams.
>> The method of at-least-once is that each incoming message has an
>> increasing numeric offset, and the idea is that successful writes into 
>> the
>> datastore would send back the last committed offset, which should 
>> increase
>> over time.  If a failure occurs, then the ingestion can be restarted from
>> the last committed offset, by replaying messages from the source (or a
>> write-ahead log, for example).
>>
>> How would I design such a system?
>>
>> Let's start with the naive implementation:
>>
>> kafkaSource.map(someTransformFunc).to(dataStoreSink)
>>
>> This gives us backpressure, but no ack feedbacks.   I can think of
>> two ways to add the ack feedback.
>>
>> One is to make the writing to the datastore not a sink but a mapAsync
>> stage that uses futures to write, and returns the latest completed 
>> offset.
>>
>> kafkaSource.map(someTransformFunc).mapAsync(writeToDataStoreFuture _)
>>
>> This is incomplete, because there is no flow.  Ideally, the stream of
>> completed offsets would be fed back to kafkaSource so it knows the latest
>> committed offset, and if some error occurred (possibly also a result), 
>> then
>> the source could replay messages.  How to do this?
>>
>> A second approach, which seems hacky and not so idiomatic, is to make
>> kafkaSource and dataStoreSink into ActorPublisher and ActorSubscribers,
>> respectively.  Then, the dataStoreSink could send out of band ack 
>> messages
>> to the kafkaSource actor directly.
>>
>> It's not clear to me that backpressure is really needed for the acks,
>> I think the most critical part is that writing to the datastore has
>> backpressure.
>>
>> Any thoughts?
>>
>> Many thanks,
>> Evan
>>
>>--
> >> 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+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>



 

Re: [akka-user] tcp client server recommendations

2015-02-02 Thread Endre Varga
On Sun, Feb 1, 2015 at 9:05 PM, Jeremy Stone 
wrote:

> Would something like the following in the server handler do it for you?...
>
> def silentSource = ??? // Source that emits nothing but does never
> completes
> def handleDataFromClient: ByteString => Unit = ???
>
> ForeachSink[StreamTcp.IncomingConnection] { conn =>
>   println("Client connected from: " + conn.remoteAddress)
>
>   silentSource.via(conn.flow).to(Sink.foreach(handleDataFromClient)).
> run
> }
>
> AFAIK there is no silent, non-completing Source implementation shipped
> with the akka streams library (1.0-M2).
>

Now there is: https://github.com/akka/akka/pull/16750

Will be available in M3.

-Endre


>  We had a similar situation and had to create one using a very simple
> ActorPublisher. Alternatively, maybe first try it using a TickSource with a
> long initial delay.
>
> --
> >> 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+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>

-- 
>>  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+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.