Hi all, I am doing some testing with akka-http and chunked encoding. I want to investigate the backpressure behavior, so I am using curl with --limit-rate 1k on the client side. I should I see backpressure when using akka-http to send a HttpEntity.Chunked, right?
One thing I noticed is that all hell breaks loose when the connection is closed from the client side (e.g. by interrupting curl using Control-C). See below. Is that going to change with 1.0, or is there a way to silence this? Also, is the namespace for the scala dsl going to stay scaladsl**2**? That would be weird. cheers, Rüdiger --- FINE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: Closing connection due to IO error java.io.IOException: Connection reset by peer, source: akka://Server/system/IO-TCP/selectors/$a/39class: class akka.io.TcpIncomingConnection WARNING: 2014/10/28 10:12:16:484: satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: DeadLetter(ChannelReadable,Actor[akka://Server/deadLetters],Actor[akka://Server/system/IO-TCP/selectors/$a/39#-1098197434]) SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/IO-HTTP/$a/flow-552-1-rootParserclass: class akka.stream.impl.TransformProcessorImpl: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer WARNING: 2014/10/28 10:12:16:484: satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: DeadLetter(Abort,Actor[akka://Server/system/IO-TCP-STREAM/server-1-%2F0.0.0.0%3A8888/$M#801209365],Actor[akka://Server/system/IO-TCP/selectors/$a/39#-1098197434]) SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/IO-HTTP/$a/flow-552-2-splitWhenclass: class akka.stream.impl2.SplitWhenProcessorImpl: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/IO-HTTP/$a/flow-555-1-prefixAndTailclass: class akka.stream.impl2.PrefixAndTailImpl: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer WARNING: 2014/10/28 10:12:16:484: satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: DeadLetter(Terminate(),Actor[akka://Server/user/IO-HTTP/$a/flow-560-0-iterator#435212900],Actor[akka://Server/user/IO-HTTP/$a/flow-560-0-iterator#435212900]) SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/IO-HTTP/$a/flow-552-3-mapclass: class akka.stream.impl.TransformProcessorImpl: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer WARNING: 2014/10/28 10:12:16:484: satmonjavaservices.server.SatmonJavaServices$$anonfun$1$$anon$4$$anonfun$receive$1: DeadLetter(Cancel(akka.stream.impl.ActorSubscription@4a9cf35),Actor[akka://Server/deadLetters],Actor[akka://Server/user/IO-HTTP/$a/flow-552-4-concatFlatten#1535190045]) SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/IO-HTTP/$a/flow-552-4-concatFlattenclass: class akka.stream.impl2.ConcatAllImpl: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/IO-HTTP/$a/flow-547-broadcastclass: class akka.stream.impl2.Broadcast: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/IO-HTTP/$a/flow-548-1-collectclass: class akka.stream.impl.TransformProcessorImpl: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer SEVERE: 2014/10/28 10:12:16:484: satmonjavaservices.akka.EventListener$$anonfun$receive$1: failure during processing, source: akka://Server/user/$b/flow-554-1-mapAsyncUnorderedclass: class akka.stream.impl2.MapAsyncUnorderedProcessorImpl: akka.stream.io.TcpStreamActor$TcpStreamException: The connection closed with error Connection reset by peer -- >>>>>>>>>> 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 [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
