-pool-executor.
>
> > Or it intended that every Flow is doing his work in it's own thread?
>
> No.
>
> -Endre
>
>
>
> On Tue, Apr 19, 2016 at 3:48 PM, Thomas Zimmer <t.zi...@eslgaming.com
> > wrote:
>
>> Hey guys,
>>
>> I have an applic
Hey guys,
I have an application where I expect many clients to connect to via TCP. So
my design is the following. I have these two actor-types:
* Server-Actor - Accepts incoming TCP connections (Uses Reactive TCP -
Stream). Per incoming request i spawn a new "ClientSession" - actor
instance.
Hello,
I was playing around with Stream API 2.0 where I got a strange
error-message:
"Cannot materialize an incoming connection Flow twice.". I could track down
the issue to a code-line. So this what I am doing
Server code:
val connections = Tcp().bind(localHost.getHostName, port, backlog,
h 1.X versions btw, and I think it did not in
> more recent versions.
>
> -Endre
>
> On Thu, Feb 11, 2016 at 3:36 PM, Thomas Zimmer <t.zi...@eslgaming.com
> > wrote:
>
>> Hello,
>>
>> I was playing around with Stream API 2.0 where I got a strange
>&g
Excatly. I use the PROXY Protocol which only sends a string "PROXY IP IP
port port\r\n" right in the beginning. So can you think of any good
solution?
On Thursday, February 11, 2016 at 4:43:08 PM UTC+1, drewhk wrote:
>
>
>
> On Thu, Feb 11, 2016 at 4:24 PM, Thomas Zimmer
connection?
>
> -Endre
>
> On Thu, Feb 11, 2016 at 4:45 PM, Thomas Zimmer <t.zi...@eslgaming.com
> > wrote:
>
>> Excatly. I use the PROXY Protocol which only sends a string "PROXY IP IP
>> port port\r\n" right in the beginning. So can you think of an
s above, you
> can use them as a template for your own:
> https://github.com/akka/akka/blob/master/akka-stream/src/main/scala/akka/stream/impl/Timers.scala
>
> -Endre
>
> On Thu, Feb 11, 2016 at 5:04 PM, Thomas Zimmer <t.zi...@eslgaming.com
> > wrote:
>
>> Ah so
try, what did the compiler say? How did you adapt the code?
Were you able to understand what I meant with my solution?
On Mon, Jul 20, 2015 at 5:32 PM, Thomas Zimmer t.zi...@eslgaming.com
javascript: wrote:
hey do you have any code-examples? I tried:
val wrappedFlow = BidiFlow.wrap
One question in general: Is it better to have different FlowGraphs and set
them up in one large or flow or join different Flows directly to each
other?
Regards,
Thomas
On Tuesday, July 21, 2015 at 9:45:22 AM UTC+2, Thomas Zimmer wrote:
Thanks Chad and also thank you √ (Strange name
://github.com/cretz/scimap/blob/f7d7f2ed59cf423dabb460e32a38d97b872d10f9/src/main/scala/scimap/handler/FlowBuilder.scala#L95
On Monday, July 20, 2015 at 10:32:48 AM UTC-5, Thomas Zimmer wrote:
hey do you have any code-examples? I tried:
val wrappedFlow = BidiFlow.wrap(inboundFlow, outboundFlow
Hey,
I really have problems understanding the TLS Bidi-Flows. The specs are not
very helpful as they only do echo the input as fas as I understood and
there is not official documentation. What I have so far:
* A TCP flow (Flow[ByteString, ByteString])
* A logical flow (Flow[ByteString,
are connecting the
bidiflow (2 inputs and 2 outputs) to eachother, leaving no inputs nor
outputs open, which means it cannot be a Flow.
On Mon, Jul 20, 2015 at 2:58 PM, Thomas Zimmer t.zi...@eslgaming.com
javascript: wrote:
Hey,
I really have problems understanding the TLS Bidi-Flows
a join with the identity flow (Flow[Out1, In2]) or use
a Flow.apply with a builder to manually connect the ports.
On Mon, Jul 20, 2015 at 4:36 PM, Thomas Zimmer t.zi...@eslgaming.com
javascript: wrote:
Can you tell me how to setup the correct workflow here?
I would like to have:
incoming
Hi,
i got a more conceptual question. Is it more to common to emit a message to
a ActorRef directly or use the ActorSelection instead? I am thinking of the
following use-case: I got a business logic actor (A) and a persistence
logic actor (B). So if i A wants to tell B to save a DB-Entry would
point to chunk up the bytestring
into the header bytestring and payload bytestring.
B/
On 26 January 2015 at 12:09:57, Thomas Zimmer (
t...@turtle-entertainment.de javascript:) wrote:
Hi,
i have a question regarding TCP Streams and request strategies. Lets say
i have a TCPStream build
://tersesystems.com/2014/03/23/fixing-hostname-verification/
Hope that helps,
Will.
On Friday, December 19, 2014 8:56:39 AM UTC-8, Thomas Zimmer wrote:
Hi,
I also had this issue but thanks to some examples [
https://github.com/xbucchiotty/akka-stream-ssltlscipher/blob/master/src/test/scala/Test.scala
Hi,
i created a simple application
(https://gist.github.com/Alien2150/9468c871135fd94869a2) to play around
with the SSL-Stream. But as soon as my client has been closed I am seeing
this log-message (without receiving any OnComplete messages):
[INFO] [01/07/2015 14:12:53.549]
Hi,
I also had this issue but thanks to some examples
[https://github.com/xbucchiotty/akka-stream-ssltlscipher/blob/master/src/test/scala/Test.scala]
and of course the TLS Specs
:
ServerBinding.Connections - TlsCipher - SessionInboundData.
Regards,
Thomas
On Friday, December 19, 2014 8:31:23 PM UTC+1, rkuhn wrote:
Thanks for sharing!
19 dec 2014 kl. 17:56 skrev Thomas Zimmer t...@turtle-entertainment.de
javascript::
Hi,
I also had this issue but thanks to some
19 matches
Mail list logo
