[akka-user] New to Akka, newbie to high scale server programming

2016-10-31 Thread Alireza Mohamadi 
Hi. As I mentioned, consider me as a newbie who is only good at coding.
I want to write a project which I believe will have many simultaneous HTTP 
requests and many simultaneous DB queries being executed.
I decided to choose Akka vs Quasar at last, and want to ask about how to 
fit my scenario in order to enjoy Akka miracles.
My scenario is, client sends a request, I refer to DB in order to read 
his/her data, and then I do some processes and send a response. That's all! 
But in a very parallel manner.
So this scenario is severely blocking. You say, use futures and let your 
actor do something else. That's called transforming a synchronous model to 
an asynchronous one.
OK, I use futures, but send my actor to do what? Exactly what can I do in 
this case? Also let us assume I can suggest other jobs for this actor, how 
can I enjoy multiple threads running on a multi-core CPU? I have an actor 
which is cleaning the house until the pizza delivery arrives. So I hire 
another actor to help her, but what do I suggest to second actor? Feeding 
the cat? What if I don't have a cat?
I mean that, in blocking (synchronous) model (Quasar uses, you know) it is 
simple. If you block an actor, we create another to do the same job but in 
parallel. They can both work on different tasks, but can easily get 
blocked. I don't want this model because I have chosen Akka, and I want to 
learn how can I transform that model efficiently to a non-blocking one so I 
can enjoy efficient parallelism.
Thanks

-- 
>>  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] http proxy support

2016-10-31 Thread subopt1 
I'm interested in proxying http requests with akka-http. Based on what I've 
read so far I need to enable the configuration and then it should work with 
Http().singleRequest
however it's not connecting through the proxy. I have the following config 
in application.conf

akka.http {

host-connection-pool {

  client {

proxy {

  http {

host = 127.0.0.1

post = 

  }

}

  }

}
}

and following code

val responseFuture: Future[HttpResponse] =
  Http().singleRequest(HttpRequest(uri = "http://akka.io;))


val response: HttpResponse = Await.result(responseFuture, Duration.Inf)

println(response.status.intValue())


SBT has


libraryDependencies += "com.typesafe.akka" %% "akka-http-core" % "2.4.11"
libraryDependencies += "com.typesafe.akka" %% "akka-http-experimental" % 
"2.4.11"

-- 
>>  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] [akka-persistence] readjournal query by multiple tags

2016-10-31 Thread jsoeters 
Is there a feature (planned?) to support querying the read journal by 
multiple tags. Typically projections in an event sourced application only 
update from a very small subset of the events. Say I have a UserProjection 
that creates/updates a UserReadModel from a UserRegistered event and all 
other User* events don't affect that read model. In this case it would be 
useful to have a queryByTags(Seq("UserRegistered"), ) method on the 
read journal which would make (re)building that projection much more 
efficient.

-- 
>>  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] How to reference an existing actor?

2016-10-31 Thread Harinath Mallepally 
Hi,

I am using this deprecated method for referencing existing actor, is this 
the right approach? given that I have created a actor with a unique name, I 
want to reference is so that I can use it.

 ActorRef actor = actorSystem.actorFor(actorSystem.child()

I always get not null value even if the actor doesn't exist.

Thanks
Hari

-- 
>>  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] Can a cluster have multiple singleton actors?

2016-10-31 Thread Justin Robbins 
Great.  Then I'm confused what the config would look like.  Would something 
like the following work?

cluster {
  singleton {
singleton-name = "singleton1"
  }
  singleton-proxy {
singleton-name = *"*singleton1"
  }
}


cluster {
  singleton {
singleton-name = "singleton2"
  }
  singleton-proxy {
singleton-name = *"*singleton2"
  }
}


On Monday, October 31, 2016 at 9:31:45 AM UTC-6, Patrik Nordwall wrote:
>
> You can create many different ClusterSingletonManager actors with 
> different settings, each one managing one singleton.
>
> Regards,
> Patrik
>
>
>
> On Mon, Oct 31, 2016 at 4:18 PM, Justin Robbins  > wrote:
>
>> Hi, I posted this question 
>> 
>>  
>> over on Stack Overflow but I figured I'd also post it here since Akka.com 
>> lists this mailing list as a place for community support.
>>
>>
>> Can there be multiple different actors which are singletons in an Akka 
>> cluster?
>>
>>
>> For example, let's say I need a single entry point into *multiple* systems. 
>> I might want *Singleton1* to be responsible for entry into *System1* and 
>> *Singleton2* to be responsible for entry into *System2*. It does not 
>> seem ideal to have a single singleton Actor with multiple responsibilities. 
>> I'm of course ok with both singleton actors running on the same node.
>>
>>
>> The Akka docs 
>>  state 
>> the ClusterSingletonManager "manages one singleton actor instance among all 
>> cluster nodes or a group of nodes." This, along with the Configuration 
>> documentation example, lead me to conclude what I'm asking for is not 
>> possible, but I figured I'd ask to confirm. Thanks!
>>
>> -- 
>> >> 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 https://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> -- 
>
> Patrik Nordwall
> Akka Tech Lead
> Lightbend  -  Reactive apps on the JVM
> Twitter: @patriknw
>
>

-- 
>>  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] What are the Best Practices for building Rest services with Akka Http?

2016-10-31 Thread Sriram P 

Could anyone suggest/share the best practices/guidelines for building the 
REST services(micro) using akka http, Json, Slick, Logging, authentication, 
authorization, dependency injection etc.
Please share if any good templates available for building the production 
ready code, where I just need to concentrate on writing business logic 
quickly and no need to worry about the above said topics. :)

Thanks a Lot!

-- 
>>  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] Actor systems in the cluster are quarantined too often

2016-10-31 Thread Patrik Nordwall 
On Sat, Oct 29, 2016 at 5:57 PM, Eugene Dzhurinsky 
wrote:

> Patrick, thanks for the quick reply!
>
> In fact I do see it happening quite often, I have akka *INFO* logging
> enabled, please take a look at this one:
>
> http://depnongadsla.s3.amazonaws.com/wrapper-20161029.log
>
>
Can you somehow verify if those are real network issues, e.g. by using some
other non-Akka software to verify the connectivity?

Change

akka.cluster.failure-detector {
  acceptable-heartbeat-pause = 10 s
  heartbeat-interval = 1 s
}

akka.cluster.auto-down-unreachable-after = 300s


Look for this in the logs: "Marking node(s) as UNREACHABLE"
That means that the failure detector heartbeat messages don't get through
and then it's interesting to see it that is because you have a real network
issue or if it's something related to Akka or your application.

If the network partition "heals" you should see: "Marking node(s) as
REACHABLE"



> To make it clear: all addresses *192.168.1.** are located in the same
> datacenter in US, *10.9.0.** are located in EU.
>
> I hope that will give you some idea of what's wrong over there.
>
> I quite don't understand why the leader is set to *10.9.0.10* sometimes,
> I supposed leader to be in *192.168.1.**
>

Leader is selected by sorting the addresses alphanumerically. 10.9.0.10
< 192.168.1.*


>
> Thanks!
>
> --
> >> 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.
>



-- 

Patrik Nordwall
Akka Tech Lead
Lightbend  -  Reactive apps on the JVM
Twitter: @patriknw

-- 
>>  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] ANNOUNCE: Akka 2.3.16 released

2016-10-31 Thread Johan Andrén 


*Dear hAkkers,*

We—the Akka committers—are pleased to be able to announce the availability 
of Akka 2.3.16. This is the 16th maintenance release of the 2.3 branch. 
This release contains three bugfixes:

   - Wraparound issue with the scheduler causing it to stop function 
   correctly 20424 
   - Issue in ConsistentHashingRouter causing problems for DNS resolution 
   in Akka 20263 
   - Backport of a serialization issue around scala.Option in Akka 
   Persistence 16659 

The complete list of closed tickets can be found in the 2.3.16 github 
issues milestone 
.

Akka 2.3.16 is released for Scala 2.10 and 2.11. This release is backwards 
binary compatible with all previous 2.3.x versions which means that the new 
JARs are a drop-in replacement for the old one (but not the other way 
around) as long as your build does not enable the inliner (Scala-only 
restriction). Always make sure to use at least the latest version required 
by any of your project’s dependencies.
Additional Release Details

The artifacts comprising this release have been published to 
https://oss.sonatype.org/content/repositories/releases/ and also to Maven 
Central. In addition, we adopted the sbt standard of encoding the Scala 
binary version in the artifact name, i.e. the core actor package’s 
artifactId is “akka-actor_2.10” or “akka-actor_2.11”, respectively.
Credits

commits added removed
  250   5 Patrik Nordwall
  1   139  26 Roland Kuhn

*Happy hAkking!*

-- 
>>  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] Can a cluster have multiple singleton actors?

2016-10-31 Thread Patrik Nordwall 
You can create many different ClusterSingletonManager actors with different
settings, each one managing one singleton.

Regards,
Patrik



On Mon, Oct 31, 2016 at 4:18 PM, Justin Robbins 
wrote:

> Hi, I posted this question
> 
> over on Stack Overflow but I figured I'd also post it here since Akka.com
> lists this mailing list as a place for community support.
>
>
> Can there be multiple different actors which are singletons in an Akka
> cluster?
>
>
> For example, let's say I need a single entry point into *multiple* systems.
> I might want *Singleton1* to be responsible for entry into *System1* and
> *Singleton2* to be responsible for entry into *System2*. It does not seem
> ideal to have a single singleton Actor with multiple responsibilities. I'm
> of course ok with both singleton actors running on the same node.
>
>
> The Akka docs
>  state
> the ClusterSingletonManager "manages one singleton actor instance among all
> cluster nodes or a group of nodes." This, along with the Configuration
> documentation example, lead me to conclude what I'm asking for is not
> possible, but I figured I'd ask to confirm. Thanks!
>
> --
> >> 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.
>



-- 

Patrik Nordwall
Akka Tech Lead
Lightbend  -  Reactive apps on the JVM
Twitter: @patriknw

-- 
>>  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] Can a cluster have multiple singleton actors?

2016-10-31 Thread Justin Robbins 


Hi, I posted this question 

 
over on Stack Overflow but I figured I'd also post it here since Akka.com 
lists this mailing list as a place for community support.


Can there be multiple different actors which are singletons in an Akka 
cluster?


For example, let's say I need a single entry point into *multiple* systems. 
I might want *Singleton1* to be responsible for entry into *System1* and 
*Singleton2* to be responsible for entry into *System2*. It does not seem 
ideal to have a single singleton Actor with multiple responsibilities. I'm 
of course ok with both singleton actors running on the same node.


The Akka docs 
 state 
the ClusterSingletonManager "manages one singleton actor instance among all 
cluster nodes or a group of nodes." This, along with the Configuration 
documentation example, lead me to conclude what I'm asking for is not 
possible, but I figured I'd ask to confirm. Thanks!

-- 
>>  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] Akka Streams - output CSV - how to know last line so can avoid appending new line character

2016-10-31 Thread Viktor Klang 
You're most welcome.

On Mon, Oct 31, 2016 at 2:49 PM, Gary Malouf  wrote:

> Ah - missed that in the API - thanks for the pointer!
>
> On Mon, Oct 31, 2016 at 9:47 AM, Viktor Klang 
> wrote:
>
>> intersperse?
>>
>> On Mon, Oct 31, 2016 at 2:40 PM, Gary Malouf 
>> wrote:
>>
>>> I am attempting to use Akka streams to read a large amount of data from
>>> a database (in chunks) and output to a CSV on S3.  While it may seem
>>> trivial, I'm trying to find the best way to identify the final line of the
>>> to be created file and avoid putting a new line character at the end of
>>> it.  Is there anyway to do this via the Source API?
>>>
>>> --
>>> >> Read the docs: http://akka.io/docs/
>>> >> Check the FAQ: http://doc.akka.io/docs/akka/c
>>> urrent/additional/faq.html
>>> >> Search the archives: https://groups.google.com/grou
>>> p/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.
>>>
>>
>>
>>
>> --
>> Cheers,
>> √
>>
>> --
>> >> Read the docs: http://akka.io/docs/
>> >> Check the FAQ: http://doc.akka.io/docs/akka/c
>> urrent/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/to
>> pic/akka-user/5mZUJzAdacM/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.
>



-- 
Cheers,
√

-- 
>>  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] Akka Streams - output CSV - how to know last line so can avoid appending new line character

2016-10-31 Thread Gary Malouf 
Ah - missed that in the API - thanks for the pointer!

On Mon, Oct 31, 2016 at 9:47 AM, Viktor Klang 
wrote:

> intersperse?
>
> On Mon, Oct 31, 2016 at 2:40 PM, Gary Malouf 
> wrote:
>
>> I am attempting to use Akka streams to read a large amount of data from a
>> database (in chunks) and output to a CSV on S3.  While it may seem trivial,
>> I'm trying to find the best way to identify the final line of the to be
>> created file and avoid putting a new line character at the end of it.  Is
>> there anyway to do this via the Source API?
>>
>> --
>> >> Read the docs: http://akka.io/docs/
>> >> Check the FAQ: http://doc.akka.io/docs/akka/c
>> urrent/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.
>>
>
>
>
> --
> Cheers,
> √
>
> --
> >> 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/5mZUJzAdacM/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.

Re: [akka-user] Akka Streams - output CSV - how to know last line so can avoid appending new line character

2016-10-31 Thread Viktor Klang 
intersperse?

On Mon, Oct 31, 2016 at 2:40 PM, Gary Malouf  wrote:

> I am attempting to use Akka streams to read a large amount of data from a
> database (in chunks) and output to a CSV on S3.  While it may seem trivial,
> I'm trying to find the best way to identify the final line of the to be
> created file and avoid putting a new line character at the end of it.  Is
> there anyway to do this via the Source API?
>
> --
> >> 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.
>



-- 
Cheers,
√

-- 
>>  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] Akka Streams - output CSV - how to know last line so can avoid appending new line character

2016-10-31 Thread Gary Malouf 
I am attempting to use Akka streams to read a large amount of data from a 
database (in chunks) and output to a CSV on S3.  While it may seem trivial, 
I'm trying to find the best way to identify the final line of the to be 
created file and avoid putting a new line character at the end of it.  Is 
there anyway to do this via the Source API?

-- 
>>  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.