Glad you found it, thanks for closing the loop here!
Regards,
Roland
> 23 mar 2015 kl. 09:54 skrev zergood :
>
> I had found the issue. The reason was frame coding. I supposed that every
> message is send in single tcp packet but it is not. Now I have implemented
> frame coding/decoding and
My mistake.
четверг, 19 марта 2015 г., 23:07:15 UTC+3 пользователь √ написал:
>
> This looks weird:
>
> val file = scala.io.Source.fromFile(new File("./logfile.txt"))
> val lines = file.getLines() <-- getLines here?
>
> Source(() => file.getLines()).map(line => {
>
> On Thu, Mar 19, 2015 at 8
This looks weird:
val file = scala.io.Source.fromFile(new File("./logfile.txt"))
val lines = file.getLines() <-- getLines here?
Source(() => file.getLines()).map(line => {
On Thu, Mar 19, 2015 at 8:28 PM, Martynas Mickevičius <
martynas.mickevic...@typesafe.com> wrote:
> Hi,
>
> are you sur
Hi,
are you sure you do not stop this actor or the whole ActorSystem while the
transfer is still going?
On Thu, Mar 19, 2015 at 1:32 AM, zergood wrote:
> Hi!
>
> I want to stream file lines through tcp to server.
>
> Here is the code:
>
> class StreamingTcpActor(remoteAddress:InetSocketAddress,
Hi!
I want to stream file lines through tcp to server.
Here is the code:
class StreamingTcpActor(remoteAddress:InetSocketAddress, system: ActorSystem){
implicit val actorSystem = system
implicit val materializer = ActorFlowMaterializer()
val connection = StreamTcp().outgoingConnection(rem
