Thanks Endre,
Helpers or a couple of lines in the Akka documentation. Which BTW is a
great resource.
-chhil
On Fri, Aug 19, 2016, 4:47 PM Akka Team wrote:
> Hi,
>
> On Fri, Aug 19, 2016 at 12:41 PM, murtuza chhil wrote:
>
>> Thank you for the pointer.
>>
>&g
tem).outgoingConnection("127.0.0.1", 6000);
Source clientSource = Source.single(ByteString
.fromString("Chhil"));
clientSource.via(flow).to(Sink.ignore()).run(mat);
```
-chhil
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>&g
ers or snippets would be greatly appreciated. Yes I am not used to
this paradigm of programming but trying to figure it out.
-chhil
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>&g
Source clientSource1 = Source.single(ByteString
.fromString("Chhil"));
NotUsed var = clientSource1.via(outgoingConnection).to(Sink.ignore())
.run(mat);
Managed to get a connection made usingSource.empty() for the initial
connect.
The Completion
will be sent out.
This was the reason I was seeing multiple connections.
Thank you. Appreciate the help.
-chhil
On Monday, August 1, 2016 at 2:57:47 PM UTC+5:30, Konrad Malawski wrote:
>
> Source.single completes the stream (closes the connection) once it has
> signalled the data.
&g
s.
My problem was resolved in this thread
<https://groups.google.com/d/msg/akka-user/p4aWQQEJQts/qNFCDLjoBgAJ>.
-chhil
On Monday, August 1, 2016 at 12:45:22 PM UTC+5:30, Johan Andrén wrote:
>
> Hi Chhil,
>
> If you do not care about any incoming data from the TCP server Sink.ignor
ing to be the max value outputted and zip1.in0, zip1.in1 and
zip2.in1 are going to take the 3 numbers as input (via the
source.single(..)).
Remember zip2.in0 is connected with zip1.out.
-chhil
On Thursday, August 4, 2016 at 11:36:08 PM UTC+5:30, gitted wrote:
>
>
>1. Hello,
>
&
age cs = FileIO.fromPath(file)
.via(Framing.delimiter(ByteString.fromString("\r\n"), 10))
.map(str -> {
System.out.println(str.utf8String());
return str.concat(ByteString.fromString("\r\n"));
})
Denied4E93081229D790D5hTqKBgBzP1ydnHywim1E/9e/YrVnhfWyZQ+m39zdiIqoJMrd+VwOLyCBQ+pTw4DX5vByBmimSBs=
-chhil
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/curren
Its working now.
-chhil
On Monday, August 15, 2016 at 8:56:37 AM UTC+5:30, murtuza chhil wrote:
>
> Hello,
>
> Get an error downloading latest standalone release from page
> http://akka.io/downloads/
>
> The zip downlod link is
>
> http://downloads.typesafe.com/a
nes or its an older version of akka that allows
it?
-chhil
On Friday, August 19, 2016 at 2:54:36 PM UTC+5:30, Akka Team wrote:
>
>
>
> On Sun, Aug 14, 2016 at 2:18 PM, murtuza chhil > wrote:
>
>> Hi,
>>
>> I have a simple client that reads a csv file and send i
ull){
System.out.println("Error: " + t);
}
if (x!=null){
String s = String.format("%s , %l bytes
read",x.status(),x.count());
System.out.println(s);
}
return null;
});
-chhil
--
>>
//System.out.println(LogStreamProcessor.parseLineEx(x).get());
return LogStreamProcessor.parseLineEx(x).get();
}).withAttributes(ActorAttributes.supervisionStrategy(...));
So I am kinda confused on passing the strategy.
Any help will be greatly appreciated.
-chhil
--
#akka-http-2-4-11-3-0-0
"The Java DSL for the following directives pathPrefixText,
rawPathPrefixTest, rawPathPrefix, pathSuffix
accidentally used the Scala function type instead of the
java.util.function.Function"
-chhil
On Thursday, October 20, 2016 at 10:33:03 PM UTC+5:30, murtuza c
Thanks Konrad.
-chhil
On Wednesday, October 26, 2016 at 6:01:34 PM UTC+5:30, Konrad Malawski
wrote:
>
> Well that's exactly the thing we fixed.
> As you've found in the docs.
>
> We'll release a stable this week, please upgrade then.
>
> --
> Konrad
Though my code is not HTTP related, so whatever is fixed will fix my
problem too , right?
-chhil
On Wednesday, October 26, 2016 at 6:08:21 PM UTC+5:30, murtuza chhil wrote:
>
> Thanks Konrad.
>
> -chhil
>
>
> On Wednesday, October 26, 2016 at 6:01:34 PM UTC+5:30, Kon
16 matches
Mail list logo
