[akka-user] [ANN] dendrites, library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, etc.

[Gary Struthers]

Inspired by Jonas Bonér's *Reactive Microservices Architecture* but for 
Akka Streams with Kafka, Avro, Cassandra, Akka HTTP, Algebird, & Actors 
with Typesafe Config and Logging.

Custom stream stages post-process calls that return errors or throw 
exceptions, some use Akka Streams Supervision. Queueing stages use 
backpressure to push a specified number of elements.  Akka Streams built-in 
stages are a nice use of partially applied functions and currying: apply 
some arguments while initializing streams, apply another as a stage input. 

Users can start with examples and substitute their code and configurations. 
They can also use stream stages as templates for their custom ones.

This began as a scratchpad for learning these technologies. To my surprise, 
Akka and Scala kept me free to experiment and change directions without 
painting myself into a corner. It also kept me free to blur the line 
between generic and custom where more could be generic but almost all of it 
is easily replaced. 

Documentation: https://garyaiki.github.io/dendrites/
Readme setup and code https://github.com/garyaiki/dendrites

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user] Re: Error in Docker container: Default journal plugin is not configured

[Evgeny Shepelyuk]

Ohh, maven. Unfortunately have no expirience how it works with akka and why
`.conf` transformation needed.

2 серп. 2017 23:52 "Jan-Terje Sørensen"  пише:

> That is the pom.xml file for transforming the config file.
>
> onsdag 2. august 2017 22.50.51 UTC+2 skrev Evgeny Shepelyuk følgende:
>>
>> Wtf is this XMl snippet ?
>
> --
> >> 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 a topic in the
> Google Groups "Akka User List" group.
> To unsubscribe from this topic, visit https://groups.google.com/d/
> topic/akka-user/LzXwJv-nfcc/unsubscribe.
> To unsubscribe from this group and all its topics, 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 https://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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Re: Error in Docker container: Default journal plugin is not configured

[Jan-Terje Sørensen]

That is the pom.xml file for transforming the config file.

onsdag 2. august 2017 22.50.51 UTC+2 skrev Evgeny Shepelyuk følgende:
>
> Wtf is this XMl snippet ?

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Re: Error in Docker container: Default journal plugin is not configured

[Evgeny Shepelyuk]

Wtf is this XMl snippet ?

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Re: Error in Docker container: Default journal plugin is not configured

[Jan-Terje Sørensen]

Just figured it out. Filename should be "application.conf" as you stated. 
And the transformer name should be "reference.conf"


reference.conf


-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Re: Error in Docker container: Default journal plugin is not configured

[Jan-Terje Sørensen]

If I change to application.conf then I get this error because 
reference.conf is missing:

INFO  [2017-08-02 20:36:38,089] akka.event.slf4j.Slf4jLogger: Slf4jLogger 
started
requirement failed: 'reference.conf' is missing persistence read journal 
plugin config path: 'akka.persistence.query.journal.leveldb'
INFO  [2017-08-02 20:36:38,130] akka.actor.CoordinatedShutdown: Starting 
coordinated shutdown from JVM shutdown hook
ERROR [2017-08-02 20:36:38,133] akka.actor.OneForOneStrategy: No 
configuration setting found for key 'max-concurrent-recoveries'
! com.typesafe.config.ConfigException$Missing: No configuration setting 
found for key 'max-concurrent-recoveries'
! at 
com.typesafe.config.impl.SimpleConfig.findKeyOrNull(SimpleConfig.java:152)
! at com.typesafe.config.impl.SimpleConfig.findOrNull(SimpleConfig.java:170)
! at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:184)
! at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:189)
! at 
com.typesafe.config.impl.SimpleConfig.getConfigNumber(SimpleConfig.java:219)
! at com.typesafe.config.impl.SimpleConfig.getInt(SimpleConfig.java:230)
! at akka.persistence.Persistence.(Persistence.scala:156)
! at akka.persistence.Persistence$.createExtension(Persistence.scala:131)
! at akka.persistence.Persistence$.createExtension(Persistence.scala:128)
! at akka.actor.ActorSystemImpl.registerExtension(ActorSystem.scala:880)
! at akka.actor.ExtensionId$class.apply(Extension.scala:77)
! at akka.persistence.Persistence$.apply(Persistence.scala:128)
! at akka.persistence.Eventsourced$class.$init$(Eventsourced.scala:51)
! at 
akka.persistence.AbstractPersistentActor.(PersistentActor.scala:409)
! at 
no.jansoren.akka.persistence.eventsourcing.EventSourcedPersistenceActor.(EventSourcedPersistenceActor.java:14)
! at 
no.jansoren.eventsourcing.PersistenceActor.(PersistenceActor.java:17)
! ... 18 common frames omitted
! Causing: java.lang.reflect.InvocationTargetException: null
! at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
! at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
! at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
! at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
! at akka.util.Reflect$.instantiate(Reflect.scala:65)
! at 
akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:96)
! at akka.actor.Props.newActor(Props.scala:213)
! at akka.actor.ActorCell.newActor(ActorCell.scala:563)
! at akka.actor.ActorCell.create(ActorCell.scala:589)
! ... 9 common frames omitted
! Causing: akka.actor.ActorInitializationException: 
akka://actor-system/user/PersistenceActor: exception during creation
! at akka.actor.ActorInitializationException$.apply(Actor.scala:191)
! at akka.actor.ActorCell.create(ActorCell.scala:608)
! at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462)
! at akka.actor.ActorCell.systemInvoke(ActorCell.scala:484)
! at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
! at akka.dispatch.Mailbox.run(Mailbox.scala:223)
! at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
! at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
! at 
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
! at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
! at 
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  



onsdag 2. august 2017 21.47.42 UTC+2 skrev Evgeny Shepelyuk følgende:
>
> May I assume that you should use `application.conf` in your code, not 
> `reference.conf` as you've mentioned in the post.

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Error in Docker container: Default journal plugin is not configured

[Evgeny Shepelyuk]

May I assume that you should use `application.conf` in your code, not 
`reference.conf` as you've mentioned in the post.

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user] Re: Akka Camel and Akka Streams

['Martin Krasser' via Akka User List]

Hi Sam,

not yet, only auto-acks at the moment. I created a ticket for 
application-level acks https://github.com/krasserm/streamz/issues/40. 
Feel free to comment if you think something is missing.


Cheers,
Martin

On 01.08.17 16:21, Sam D wrote:

Martin,

Is there an Ack or Nack/Status.Failure mechanism with the new streamz 
camel api like in the akka-camel actor Consumer api?


Thanks,
Sam

On Thursday, July 13, 2017 at 4:16:52 AM UTC-4, Andreas Gies wrote:

Hi,

thanks for the pointer to the Camel docs. I knew I had a blindspot
somewhere.

Best regards
Andreas

Am Dienstag, 11. Juli 2017 14:26:09 UTC+2 schrieb Andreas Gies:

Hello HAkkers,

we are maintaining an integration framework (OSGi) project
built on top of ActiveMQ, Spray and Camel implemented in Scala [1]

Most of our internal API's rely on Akka and some also on the
Akka-Camel integration.


With the next major release we plan to upgrade our Spray
routes to Akka-Http. Now that I have started looking at the
concrete
steps I have noticed that Akka-Camel is also deprecated and to
be replaced with alpakka.

I had a look through the Alpakka project. So far I haven't
found the replacement for the Akka-Camel efforts in there.
Perhaps I have overlooked something or is the replacement just
on the roadmap ?

Also I did have a look at the JMS part of Alpakka. It seems
that this implementation currently only supports TextMessages
and ignores any properties within the message. If I understand
the implementation correctly, it would fail the stream in case
of any JMSException and also when the buffer has been filled up ?

On a broader level I was wondering if the implementation
should be in the form that the inbound stream fails if and
only if
the connection is irrecoverably broken and in other cases the
Stream should reconnect transparently.

Also on a broader level I have noticed, that the messages are
acknowledged as soon as they pushed. Coming from a JMS
background that feels a bit strange to me, but that might be
because I am unfamiliar with the streaming API. In our world
a message is normally acknowledged when it has been processed
successfully (which is normally it has been written to
the file system, forwarded to another JMS destination or
triggered some execution in the database).

If the container crashes before it has acknowledged the
message, the message will be redelivered. In cases we encounter
an error we pass the message to an error handling destination
or a retry destination.


Apparently the architecture and the acceptance level of
message loss changes when switching to a streaming approach.


For now I have some concrete questions:

1) Have I missed the Camel replacement in Alpakka and if so,
where is it located within Alpakka ?
2) How are others coping with the "window of potential message
loss" when migrating from pure JMS flows to streams ?
3) Any pointers to good hands-on white papers are much
appreciated. I have read through some and also through most
of the streams documentation, but I guess I need to get my
hands dirty ...
4) I don't dare to ask, but if anyone is using Akka / AkkaHttp
and / or AkkaStream within OSGi I would be more than happy
to exchange experiences & ideas.

[1] https://github.com/woq-blended/blended



Thanks in advance for your attention
Best regards
Andreas

--
>> 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 a topic in the 
Google Groups "Akka User List" group.
To unsubscribe from this topic, visit 
https://groups.google.com/d/topic/akka-user/tl7Gj-nijiw/unsubscribe.
To unsubscribe from this group and all its topics, 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.


--
Martin Krasser

blog:http://krasserm.github.io
code:http://github.com/krasserm
twitter: http://twitter.com/mrt1nz

--

 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 

[akka-user] Error in Docker container: Default journal plugin is not configured

[Jan-Terje Sørensen]

Hi,

I am working on getting my akka-persistence app to run in Docker. When I 
run the application from Intellij it works as intended, but when i deploy 
the same files(jar & config) to Docker and try to run it from the container 
i get this error: 
```
[ERROR] [08/02/2017 11:04:10.226] 
[actor-system-akka.actor.default-dispatcher-2] 
[akka://actor-system/user/PersistenceActor] requirement failed: default 
journal plugin is not configured, see 'reference.conf'
akka.actor.ActorInitializationException: 
akka://actor-system/user/PersistenceActor: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:191)
at akka.actor.ActorCell.create(ActorCell.scala:608)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:484)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282)
at akka.dispatch.Mailbox.run(Mailbox.scala:223)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at 
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at 
akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at 
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method)
at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at akka.util.Reflect$.instantiate(Reflect.scala:65)
at 
akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:96)
at akka.actor.Props.newActor(Props.scala:213)
at akka.actor.ActorCell.newActor(ActorCell.scala:563)
at akka.actor.ActorCell.create(ActorCell.scala:589)
... 9 more
Caused by: java.lang.IllegalArgumentException: requirement failed: default 
journal plugin is not configured, see 'reference.conf'
at scala.Predef$.require(Predef.scala:224)
at 
akka.persistence.Persistence.defaultJournalPluginId$lzycompute(Persistence.scala:163)
at 
akka.persistence.Persistence.defaultJournalPluginId(Persistence.scala:161)
at 
akka.persistence.Persistence.journalConfigFor(Persistence.scala:239)
at akka.persistence.Eventsourced$class.$init$(Eventsourced.scala:61)
at 
akka.persistence.AbstractPersistentActor.(PersistentActor.scala:409)
at 
no.jansoren.akka.persistence.eventsourcing.EventSourcedPersistenceActor.(EventSourcedPersistenceActor.java:14)
at 
no.jansoren.eventsourcing.PersistenceActor.(PersistenceActor.java:21)
... 18 more
```

My `reference.conf` file looks like this:

```
akka {
  loggers = ["akka.event.slf4j.Slf4jLogger"]
  loglevel = "DEBUG"
  logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"

  persistence {
journal {
  plugin = "akka.persistence.journal.leveldb"
  leveldb.dir = "target/journal"
}
snapshot-store {
  plugin = "akka.persistence.snapshot-store.local"
  local.dir = "target/snapshots"
}
  }
  actor {
warn-about-java-serializer-usage = false
  }
}
```

Any suggestions on how to attack this issue?

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user] Flow.fromSinkAndSource and backpressure

[Konrad “ktoso” Malawski]

Good point, I missed that word in the question - thanks and sorry about
that :)
A full clarification was still useful I hope though, cheers!

—
Konrad `kto.so` Malawski
Akka  @ Lightbend 

On 2 August 2017 at 15:45:51, Alexey Shuksto (seig...@gmail.com) wrote:

Hi Konrad,

Jeff was asking about 'backpressure propagation'. From my understanding
that means that when source wasn't pulled, sink would not pull. And that's
not how it works as you already mentioned.

-- 
>> 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 https://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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user] Flow.fromSinkAndSource and backpressure

[Alexey Shuksto]

Hi Konrad,

Jeff was asking about 'backpressure propagation'. From my understanding that 
means that when source wasn't pulled, sink would not pull. And that's not how 
it works as you already mentioned. 

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user] Flow.fromSinkAndSource and backpressure

[Konrad “ktoso” Malawski]

Hi Jeff,

Alexey, that’s not correct, back-pressure works there - because it has to:
it is enforced by the reactive-streams protocol that we follow by heart in
Akka streams.

Yes, back-pressure works, the one sentence explanation would be:
“independently on each side of the newly constructed flow”.

So if the Sink you created that Flow from does not pull, no one will be
able to push data into that “Flow”.
Similarly, your Source, that created this Flow’s “output”, is not pulled
“from” it is not allowed to push data - it is being back-pressured.

Since completion was mentioned, indeed completion does not carry over from
one end to the other,
since they’re intentionally separate here. If you want to bind the
completion events use Flow.fromSinkAndSourceCoupled.

Happy hakking!

—
Konrad `kto.so` Malawski
Akka  @ Lightbend 

On 2 August 2017 at 15:31:16, Alexey Shuksto (seig...@gmail.com) wrote:

Nope. More so, completion of one of them would not cause completion of
another and flow itself.

-- 
>> 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 https://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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Flow.fromSinkAndSource and backpressure

[Alexey Shuksto]

Nope. More so, completion of one of them would not cause completion of another 
and flow itself. 

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.