Thanks for response!
I created issue https://github.com/akka/akka/issues/16959
пятница, 27 февраля 2015 г., 13:54:35 UTC+4 пользователь drewhk написал:
Hi Boris,
On Fri, Feb 27, 2015 at 10:41 AM, Boris Lopukhov 89b...@gmail.com
javascript: wrote:
I have a simple actor publisher:
class
Hi all!
How can i do a Source[Source[String]] that periodically emit the
Source[String] with the specified interval, but only if the previous
Source[String] is complete?
--
Read the docs: http://akka.io/docs/
Check the FAQ:
in mapConcat? I am using version 0.11
вторник, 18 ноября 2014 г., 17:29:54 UTC+4 пользователь Boris Lopukhov
написал:
No, the actor system is alive. Additionally, i have repeated that code
many times with the same result:
for (i - 1 to 10) {
Source(list).mapConcat(x = x).runWith
I have isolated the problem, it seems that ActorPublisher is not the cause:
val list = List.range(1, 21).grouped(5).toList
Source(list).mapConcat(x = x).runWith(ForeachSink(println))
expectation: 1..20
reality: 1..16
понедельник, 17 ноября 2014 г., 19:46:58 UTC+4 пользователь Boris
the actor system prematurely?
/Patrik
On Tue, Nov 18, 2014 at 1:24 PM, Boris Lopukhov 89b...@gmail.com
javascript: wrote:
I have isolated the problem, it seems that ActorPublisher is not the
cause:
val list = List.range(1, 21).grouped(5).toList
Source(list).mapConcat(x = x).runWith
Hi everyone!
I am trying to create a stream with an ActorPublisher:
class SourceActor extends ActorPublisher[List[Int]] {
import akka.stream.actor.ActorPublisherMessage.Request
var list = List.range(1, 21).grouped(5).toList // for example
def receive = {
case Request(elems) = while
√ написал:
Skip the merge if you only have 1 source?
On Thu, Nov 13, 2014 at 10:34 AM, Boris Lopukhov 89b...@gmail.com
javascript: wrote:
Hi everyone!
I have one or a few databases from which I want to download and process
data.
I would like to merge all sources and work with result flow
can import that one and write:
val mergedSource = sources.merge()
On Thu, Nov 13, 2014 at 3:30 PM, Boris Lopukhov 89b...@gmail.com
javascript: wrote:
Then, I want to create the mergedSource:
val mergedSource = sources match {
case List(source) = source
case manySources
I need to write a simple application that reads rows from the table of the
postgres, indexes them in elasticsearch and if successful records in
postgres that data has been indexed. Rows have sizes of about 1 Kbyte to
100MB. I'm trying to solve this with the akka-stream:
, Boris Lopukhov 89b...@gmail.com javascript:
wrote:
I need to write a simple application that reads rows from the table of
the postgres, indexes them in elasticsearch and if successful records in
postgres that data has been indexed. Rows have sizes of about 1 Kbyte to
100MB. I'm trying
.
/Patrik
On Mon, Oct 6, 2014 at 5:51 PM, Boris Lopukhov 89b...@gmail.com
javascript: wrote:
Hello,
I wrote this code:
import akka.actor.ActorSystem
import akka.stream.scaladsl2.BlackholeSink
import akka.stream.scaladsl2.FlowFrom
import akka.stream.scaladsl2.FlowMaterializer
import
Hello,
I wrote this code:
import akka.actor.ActorSystem
import akka.stream.scaladsl2.BlackholeSink
import akka.stream.scaladsl2.FlowFrom
import akka.stream.scaladsl2.FlowMaterializer
import akka.stream.scaladsl2.ThunkSource
object Main extends App {
implicit val system = ActorSystem()
12 matches
Mail list logo
