Skip to content

Instantly share code, notes, and snippets.

@jrudolph

jrudolph/trace.log

Created December 19, 2014 13:02
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jrudolph/789f1a9da85cdac5af44 to your computer and use it in GitHub Desktop.
Save jrudolph/789f1a9da85cdac5af44 to your computer and use it in GitHub Desktop.
Download ZIP
Akka HttpServer trace
Raw
trace.log
> 01 0 0 flow-1-1-map got ExposedPublisher
< 01 0 0 flow-1-1-map got ExposedPublisher
> 02 0 0 flow-1-1-map got SubscribePending$
< 02 0 0 flow-1-1-map got SubscribePending$
> 01 0 0 flow-1-2-1-foreach-stageFactory got ExposedPublisher
< 01 0 0 flow-1-2-1-foreach-stageFactory got ExposedPublisher
> 02 0 0 flow-1-2-1-foreach-stageFactory got SubscribePending$
< 02 0 0 flow-1-2-1-foreach-stageFactory got SubscribePending$
> 03 0 0 flow-1-2-1-foreach-stageFactory got OnSubscribe
< 03 0 0 flow-1-2-1-foreach-stageFactory got OnSubscribe
> 04 0 0 flow-1-2-1-foreach-stageFactory got RequestMore
< 04 0 1 flow-1-2-1-foreach-stageFactory got RequestMore
> 03 0 0 flow-1-1-map got RequestMore
< 03 0 1 flow-1-1-map got RequestMore
> 04 0 1 flow-1-1-map got OnSubscribe
About to execute: curl -v -H Expect: --form theBlob=@"/tmp/8389e139f72d63d69029531370168227880.tmp" http://127.0.0.1:49830/form
< 04 0 1 flow-1-1-map got OnSubscribe
* Hostname was NOT found in DNS cache
* Trying 127.0.0.1...
% Total % Received % Xferd Average Speed Time Time Time Current
Dload Upload Total Spent Left Speed
0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0* Connected to 127.0.0.1 (127.0.0.1) port 49830 (#0)
> POST /form HTTP/1.1
> User-Agent: curl/7.35.0
> Host: 127.0.0.1:49830
> Accept: */*
> Content-Length: 15234
> Content-Type: multipart/form-data; boundary=------------------------43912e1c0da2b93c
>
} [data not shown]
> 05 0 1 flow-1-1-map got OnNext
flow-1-1-map is pushing akka.http.HttpExt$$anon$1$$anonfun$1$$anon$2@3cbea6af
< 05 0 0 flow-1-1-map got OnNext
> 05 0 1 flow-1-2-1-foreach-stageFactory got OnNext
< 05 0 1 flow-1-2-1-foreach-stageFactory got OnNext
> 06 0 0 flow-1-1-map got RequestMore
< 06 0 1 flow-1-1-map got RequestMore
> 01 0 0 flow-4-4-errorLogger-stageFactory got ExposedPublisher
< 01 0 0 flow-4-4-errorLogger-stageFactory got ExposedPublisher
> 02 0 0 flow-4-4-errorLogger-stageFactory got SubscribePending$
< 02 0 0 flow-4-4-errorLogger-stageFactory got SubscribePending$
> 01 0 0 flow-4-3-concatAll got ExposedPublisher
< 01 0 0 flow-4-3-concatAll got ExposedPublisher
> 02 0 0 flow-4-3-concatAll got SubscribePending$
< 02 0 0 flow-4-3-concatAll got SubscribePending$
> 01 0 0 flow-4-2-renderer-stageFactory got ExposedPublisher
< 01 0 0 flow-4-2-renderer-stageFactory got ExposedPublisher
> 02 0 0 flow-4-2-renderer-stageFactory got SubscribePending$
< 02 0 0 flow-4-2-renderer-stageFactory got SubscribePending$
> 01 0 0 flow-4-1-recover-stageFactory got ExposedPublisher
< 01 0 0 flow-4-1-recover-stageFactory got ExposedPublisher
> 02 0 0 flow-4-1-recover-stageFactory got SubscribePending$
< 02 0 0 flow-4-1-recover-stageFactory got SubscribePending$
> 03 0 0 flow-4-1-recover-stageFactory got OnSubscribe
< 03 0 0 flow-4-1-recover-stageFactory got OnSubscribe
> 01 0 [0, 0] flow-5-broadcast-bypassFanout got ExposedPublishers
< 01 0 [0, 0] flow-5-broadcast-bypassFanout got ExposedPublishers
> 02 0 [0, 0] flow-5-broadcast-bypassFanout got SubstreamSubscribePending
< 02 0 [0, 0] flow-5-broadcast-bypassFanout got SubstreamSubscribePending
> 03 0 [0, 0] flow-5-broadcast-bypassFanout got SubstreamSubscribePending
< 03 0 [0, 0] flow-5-broadcast-bypassFanout got SubstreamSubscribePending
> 01 0 0 flow-7-5-mapAsync got ExposedPublisher
< 01 0 0 flow-7-5-mapAsync got ExposedPublisher
> 02 0 0 flow-7-5-mapAsync got SubscribePending$
< 02 0 0 flow-7-5-mapAsync got SubscribePending$
> 01 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got ExposedPublisher
< 01 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got ExposedPublisher
> 02 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got SubscribePending$
< 02 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got SubscribePending$
> 01 0 0 flow-7-3-concatAll got ExposedPublisher
< 01 0 0 flow-7-3-concatAll got ExposedPublisher
> 02 0 0 flow-7-3-concatAll got SubscribePending$
< 02 0 0 flow-7-3-concatAll got SubscribePending$
> 01 0 0 flow-7-2-map got ExposedPublisher
< 01 0 0 flow-7-2-map got ExposedPublisher
> 02 0 0 flow-7-2-map got SubscribePending$
< 02 0 0 flow-7-2-map got SubscribePending$
> 01 0 0 flow-7-1-splitWhen got ExposedPublisher
< 01 0 0 flow-7-1-splitWhen got ExposedPublisher
> 02 0 0 flow-7-1-splitWhen got SubscribePending$
< 02 0 0 flow-7-1-splitWhen got SubscribePending$
> 03 0 0 flow-7-1-splitWhen got OnSubscribe
< 03 0 0 flow-7-1-splitWhen got OnSubscribe
> 01 0 0 flow-9-1-rootParser-stageFactory got ExposedPublisher
< 01 0 0 flow-9-1-rootParser-stageFactory got ExposedPublisher
> 02 0 0 flow-9-1-rootParser-stageFactory got SubscribePending$
< 02 0 0 flow-9-1-rootParser-stageFactory got SubscribePending$
> 03 0 0 flow-9-1-rootParser-stageFactory got OnSubscribe
< 03 0 0 flow-9-1-rootParser-stageFactory got OnSubscribe
> 03 0 0 flow-4-4-errorLogger-stageFactory got OnSubscribe
< 03 0 0 flow-4-4-errorLogger-stageFactory got OnSubscribe
> 04 0 0 flow-4-4-errorLogger-stageFactory got RequestMore
< 04 0 1 flow-4-4-errorLogger-stageFactory got RequestMore
> 03 0 0 flow-4-3-concatAll got OnSubscribe
< 03 0 0 flow-4-3-concatAll got OnSubscribe
> 04 0 0 flow-4-3-concatAll got RequestMore
< 04 0 1 flow-4-3-concatAll got RequestMore
> 03 0 0 flow-4-2-renderer-stageFactory got OnSubscribe
< 03 0 0 flow-4-2-renderer-stageFactory got OnSubscribe
> 04 0 0 flow-4-2-renderer-stageFactory got RequestMore
< 04 0 1 flow-4-2-renderer-stageFactory got RequestMore
> 03 0 0 flow-7-5-mapAsync got OnSubscribe
< 03 0 0 flow-7-5-mapAsync got OnSubscribe
> 04 0 0 flow-7-5-mapAsync got RequestMore
< 04 0 1 flow-7-5-mapAsync got RequestMore
> 03 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got OnSubscribe
< 03 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got OnSubscribe
> 04 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got RequestMore
< 04 0 1 flow-7-4-collect-parts-collect-HttpServer.scala-65 got RequestMore
> 03 0 0 flow-7-3-concatAll got OnSubscribe
< 03 0 0 flow-7-3-concatAll got OnSubscribe
> 04 0 0 flow-7-3-concatAll got RequestMore
< 04 0 1 flow-7-3-concatAll got RequestMore
> 03 0 0 flow-7-2-map got OnSubscribe
< 03 0 0 flow-7-2-map got OnSubscribe
> 04 0 0 flow-7-2-map got RequestMore
< 04 0 1 flow-7-2-map got RequestMore
> 04 0 [0, 0] flow-5-broadcast-bypassFanout got SubstreamRequestMore
< 04 0 [0, 1] flow-5-broadcast-bypassFanout got SubstreamRequestMore
> 05 0 [0, 1] flow-5-broadcast-bypassFanout got OnSubscribe
< 05 0 [0, 1] flow-5-broadcast-bypassFanout got OnSubscribe
> 06 0 [0, 1] flow-5-broadcast-bypassFanout got SubstreamRequestMore
< 06 0 [1, 1] flow-5-broadcast-bypassFanout got SubstreamRequestMore
> 04 0 0 flow-4-1-recover-stageFactory got RequestMore
< 04 0 1 flow-4-1-recover-stageFactory got RequestMore
> 04 0 0 flow-7-1-splitWhen got RequestMore
< 04 0 1 flow-7-1-splitWhen got RequestMore
> 04 0 0 flow-9-1-rootParser-stageFactory got RequestMore
< 04 0 1 flow-9-1-rootParser-stageFactory got RequestMore
> 05 0 1 flow-9-1-rootParser-stageFactory got OnNext
Parsing part of size 807
flow-9-1-rootParser-stageFactory is pushing RequestStart(HttpMethod(POST),/form,HttpProtocol(HTTP/1.1),List(User-Agent: curl/7.35.0, Host: 127.0.0.1:49830, Accept: */*),<function1>,false,false)
< 05 0 0 flow-9-1-rootParser-stageFactory got OnNext
> 07 0 [1, 1] flow-5-broadcast-bypassFanout got OnNext
< 07 0 [0, 0] flow-5-broadcast-bypassFanout got OnNext
> 06 0 0 flow-9-1-rootParser-stageFactory got RequestMore
flow-9-1-rootParser-stageFactory is pushing EntityPart(ByteString(45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 52, 51, 57, 49, 50, 101, 49, 99, 48, 100, 97, 50, 98, 57, 51, 99, 13, 10, 67, 111, 110, 116, 101, 110, 116, 45, 68, 105, 115, 112, 111, 115, 105, 116, 105, 111, 110, 58, 32, 102, 111, 114, 109, 45, 100, 97, 116, 97, 59, 32, 110, 97, 109, 101, 61, 34, 116, 104, 101, 66, 108, 111, 98, 34, 59, 32, 102, 105, 108, 101, 110, 97, 109, 101, 61, 34, 56, 51, 56, 57, 101, 49, 51, 57, 102, 55, 50, 100, 54, 51, 100, 54, 57, 48, 50, 57, 53, 51, 49, 51, 55, 48, 49, 54, 56, 50, 50, 55, 56, 56, 48, 46, 116, 109, 112, 34, 13, 10, 67, 111, 110, 116, 101, 110, 116, 45, 84, 121, 112, 101, 58, 32, 97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 47, 111, 99, 116, 101, 116, 45, 115, 116, 114, 101, 97, 109, 13, 10, 13, 10, -124, -51, 85, 55, -102, 4, -87, 117, 34, 109, -46, 9, -53, 110, 74, 1, 25, -102, 24, -52, -56, 56, 81, -106, -82, -35, -13, -4, -48, -22, -88, 44, -107, -81, -101, 112, 88, -106, -127, -63, 17, 19, 2, -75, 98, 38, 123, 110, 62, 121, 113, -10, -29, -60, 24, -77, -36, 71, -63, -67, 124, 100, 119, 55, 83, 54, 33, -41, 17, -125, -39, 78, -56, 110, -128, -119, 7, -31, -65, 51, 117, 23, -31, 16, 42, 2, 65, -94, -78, 40, 21, -108, -112, 40, -30, -46, 66, 78, 10, 105, -19, -26, 46, 25, -26, -106, -110, 90, 59, -73, 71, -48, 67, -13, -53, -45, -96, 3, -52, 5, -97, -115, 36, 102, -9, 18, -99, -53, 7, -26, -117, 57, 104, 31, 90, -115, -50, -22, 12, 103, -14, -44, 83, 87, -113, 11, -77, -57, -38, 94, 104, -53, 26, 21, 89, 8, 79, 86, -73, -68, -20, -114, -108, 78, -47, 33, -115, 96, 40, -25, -63, 9, 22, -12, 82, 8, 39, 8, -10, -90, -127, 106, 127, -110, 27, -117, -120, 27, 108, 30, -28, -23, 96, -83, -72, -95, -52, 33, 119, -34, 94, 10, 71, -124, 3, -89, 1, 48, 57, -14, -127, -23, -44, -52, 92, 53, -96, -107, -45, 90, -45, 2, 69, 124, 116, 57, 68, 115, -48, -121, -58, -80, 32, -55, -63, -14, 9, 115, 89, -128, -38, 124, 110, 117, 35, 90, 73, 33, 42, 113, -3, 96, 63, 73, 32, 34, 94, 15, -108, 88, -86, 55, -125, 111, -32, -110, -82, -37, -18, -70, 88, 60, -126, -35, -53, 13, 85, 67, -77, 10, 61, -67, 78, 85, 32, -8, 44, -11, -6, -49, 24, -79, -7, 38, -5, -2, 87, -26, -45, 122, 105, 121, -19, 107, -114, 52, 35, 63, 99, -108, -67, 83, -29, 88, 85, 32, 23, -71, 94, -106, 68, 81, -91, 119, -81, 67, 59, -35, -2, 117, -45, -38, -88, -53, -116, -53, -67, -123, 107, 55, -37, 2, -47, 44, 42, 79, 19, -63, 124, -117, 91, -95, -33, -98, -22, -73, -106, -86, 78, 6, -106, 92, 11, 13, -53, 75, 65, 82, -76, 64, 117, 45, 94, 12, 8, 16, -95, -45, 110, 27, -40, 70, 5, -11, -111, -118, 67, 74, -55, 45, -66, 3, -95, 97, -71, 83, 102, 59, 58, -8, 122, 89, 14, -70, 33, 101, -112, -71, -33, 78, -11, 32, 107, -19, -64, -47, -60, -52, 49, -38, 54, 43, 10, 17, -26, 77, -110, -34, 3, 126, 37, -33, -4, -16, 96, -53, 112, -74, 91, 40, -3, 122, 67, -123, -89, -50, 101, 121, 7, -75, 46, -90, 35, -77, 24, -4, -16, 79, 63, -50, -98, 99, -34, 28, -118, -115, 78, -87, 39, -83, -71, -125, 22, -112, -92, 71, -77, 121, -2, -49, -117, 106, -79, -39, -90, -2, -47, -115, -112, 112, 115, -113, 39, 67, 59, 48, 88, -29, -55, -41, 55, 88, -75, -5, -50, -128, -70, 59, -23, 127, -59, 119, -89, -68, -116, -36, 44, 54, 101, -44, 87, 23, -117, 66, 4, -27, 3, -105, -2, 44, 113, -126, 39, -41, 79, -37, -56, 70, 65, 99, 88, 7, 8, 6, 85, -125, 6, 117, -13, -121, -17, -99, 29, -97, -25, -48, -116, -67, 90, 19, -7, 19, -21, -126, -112, 88, -14, 12, 47, 63, 63, 91, 66, 45, -40, 57, -78, -113, 74, 36, -113, -114, 127, -49, 125, -6, 120, -123, -116, -9, 34, -18, 40, 41, -56, 1, -96, 104, -79, 66, 46, -105, 52, 87, -97, 56, -71, -112, -126, 44, 27, -73, 105, 7, -81, 9, 86, 104, 39, 122, -58))
< 06 0 0 flow-9-1-rootParser-stageFactory got RequestMore
> 05 0 1 flow-7-1-splitWhen got OnNext
< 05 0 0 flow-7-1-splitWhen got OnNext
> 08 0 [0, 0] flow-5-broadcast-bypassFanout got OnNext
< 08 1 [0, 0] flow-5-broadcast-bypassFanout got OnNext
> 09 1 [0, 0] flow-5-broadcast-bypassFanout got SubstreamRequestMore
< 09 1 [1, 0] flow-5-broadcast-bypassFanout got SubstreamRequestMore
> 10 1 [1, 0] flow-5-broadcast-bypassFanout got SubstreamRequestMore
< 10 0 [0, 0] flow-5-broadcast-bypassFanout got SubstreamRequestMore
> 05 0 1 flow-7-2-map got OnNext
flow-7-2-map is pushing SourcePipe(PublisherSource(akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@7885f5e4),List(Map(<function1>,OperationAttributes(List(Name(map)))), PrefixAndTail(1,OperationAttributes(List(Name(prefixAndTail))))),List(),OperationAttributes(List()))
< 05 0 0 flow-7-2-map got OnNext
> 07 0 0 flow-9-1-rootParser-stageFactory got RequestMore
< 07 0 1 flow-9-1-rootParser-stageFactory got RequestMore
> 06 0 0 flow-7-1-splitWhen got OnNext
< 06 1 0 flow-7-1-splitWhen got OnNext
> 07 1 0 flow-7-1-splitWhen got RequestMore
< 07 1 1 flow-7-1-splitWhen got RequestMore
> 05 0 1 flow-7-3-concatAll got OnNext
< 05 0 1 flow-7-3-concatAll got OnNext
> 06 0 0 flow-7-2-map got RequestMore
< 06 0 1 flow-7-2-map got RequestMore
> 08 1 1 flow-7-1-splitWhen got SubstreamSubscribe
< 08 1 1 flow-7-1-splitWhen got SubstreamSubscribe
> 01 0 0 flow-10-2-map got ExposedPublisher
< 01 0 0 flow-10-2-map got ExposedPublisher
> 02 0 0 flow-10-2-map got SubscribePending$
< 02 0 0 flow-10-2-map got SubscribePending$
> 01 0 0 flow-10-1-prefixAndTail got ExposedPublisher
< 01 0 0 flow-10-1-prefixAndTail got ExposedPublisher
> 02 0 0 flow-10-1-prefixAndTail got SubscribePending$
< 02 0 0 flow-10-1-prefixAndTail got SubscribePending$
> 03 0 0 flow-10-1-prefixAndTail got OnSubscribe
< 03 0 0 flow-10-1-prefixAndTail got OnSubscribe
> 06 0 1 flow-7-3-concatAll got SubstreamStreamOnSubscribe
< 06 0 1 flow-7-3-concatAll got SubstreamStreamOnSubscribe
> 03 0 0 flow-10-2-map got OnSubscribe
< 03 0 0 flow-10-2-map got OnSubscribe
> 04 0 0 flow-10-2-map got RequestMore
< 04 0 1 flow-10-2-map got RequestMore
> 09 1 1 flow-7-1-splitWhen got SubstreamRequestMore
< 09 1 1 flow-7-1-splitWhen got SubstreamRequestMore
> 04 0 0 flow-10-1-prefixAndTail got RequestMore
< 04 0 1 flow-10-1-prefixAndTail got RequestMore
> 05 0 1 flow-10-1-prefixAndTail got OnNext
< 05 0 0 flow-10-1-prefixAndTail got OnNext
> 10 1 1 flow-7-1-splitWhen got SubstreamRequestMore
< 10 0 1 flow-7-1-splitWhen got SubstreamRequestMore
> 05 0 1 flow-10-2-map got OnNext
flow-10-2-map is pushing (RequestStart(HttpMethod(POST),/form,HttpProtocol(HTTP/1.1),List(User-Agent: curl/7.35.0, Host: 127.0.0.1:49830, Accept: */*),<function1>,false,false),PublisherSource(akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@1d03c504))
< 05 0 0 flow-10-2-map got OnNext
> 06 0 0 flow-10-2-map got OnComplete$
< 06 0 0 flow-10-2-map got OnComplete$
> 11 0 [0, 0] flow-5-broadcast-bypassFanout got SubstreamRequestMore
< 11 0 [0, 1] flow-5-broadcast-bypassFanout got SubstreamRequestMore
> 06 0 0 flow-10-1-prefixAndTail got OnNext
< 06 1 0 flow-10-1-prefixAndTail got OnNext
> 07 1 0 flow-10-1-prefixAndTail got RequestMore
< 07 1 1 flow-10-1-prefixAndTail got RequestMore
> 07 0 1 flow-7-3-concatAll got SubstreamOnNext
< 07 0 0 flow-7-3-concatAll got SubstreamOnNext
> 08 0 0 flow-7-3-concatAll got SubstreamOnComplete
< 08 0 0 flow-7-3-concatAll got SubstreamOnComplete
> 05 0 1 flow-7-4-collect-parts-collect-HttpServer.scala-65 got OnNext
flow-7-4-collect-parts-collect-HttpServer.scala-65 is pushing HttpRequest(HttpMethod(POST),http://127.0.0.1:49830/form,List(User-Agent: curl/7.35.0, Host: 127.0.0.1:49830, Accept: */*),HttpEntity.Default(multipart/form-data; boundary=------------------------43912e1c0da2b93c,15234,SourcePipe(PublisherSource(akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@1d03c504),List(Collect(<function1>,OperationAttributes(List(Name(collect-HttpMessageParser.scala-307))))),List(),OperationAttributes(List()))),HttpProtocol(HTTP/1.1))
< 05 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got OnNext
> 09 0 0 flow-7-3-concatAll got RequestMore
< 09 0 1 flow-7-3-concatAll got RequestMore
> 05 0 1 flow-7-5-mapAsync got OnNext
< 05 0 1 flow-7-5-mapAsync got OnNext
> 06 0 0 flow-7-4-collect-parts-collect-HttpServer.scala-65 got RequestMore
< 06 0 1 flow-7-4-collect-parts-collect-HttpServer.scala-65 got RequestMore
> 08 1 1 flow-10-1-prefixAndTail got SubstreamSubscribe
< 08 1 1 flow-10-1-prefixAndTail got SubstreamSubscribe
> 01 0 0 flow-11-9-map got ExposedPublisher
< 01 0 0 flow-11-9-map got ExposedPublisher
> 02 0 0 flow-11-9-map got SubscribePending$
< 02 0 0 flow-11-9-map got SubscribePending$
> 03 0 0 flow-11-9-map got RequestMore
< 03 0 1 flow-11-9-map got RequestMore
> 01 0 0 flow-11-8-mapAsync got ExposedPublisher
< 01 0 0 flow-11-8-mapAsync got ExposedPublisher
> 02 0 0 flow-11-8-mapAsync got SubscribePending$
< 02 0 0 flow-11-8-mapAsync got SubscribePending$
> 01 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got ExposedPublisher
< 01 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got ExposedPublisher
> 02 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got SubscribePending$
< 02 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got SubscribePending$
> 01 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got ExposedPublisher
< 01 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got ExposedPublisher
> 02 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got SubscribePending$
< 02 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got SubscribePending$
> 01 0 0 flow-11-5-concatAll got ExposedPublisher
< 01 0 0 flow-11-5-concatAll got ExposedPublisher
> 02 0 0 flow-11-5-concatAll got SubscribePending$
< 02 0 0 flow-11-5-concatAll got SubscribePending$
> 01 0 0 flow-11-4-map got ExposedPublisher
< 01 0 0 flow-11-4-map got ExposedPublisher
> 02 0 0 flow-11-4-map got SubscribePending$
< 02 0 0 flow-11-4-map got SubscribePending$
> 01 0 0 flow-11-3-splitWhen got ExposedPublisher
< 01 0 0 flow-11-3-splitWhen got ExposedPublisher
> 02 0 0 flow-11-3-splitWhen got SubscribePending$
< 02 0 0 flow-11-3-splitWhen got SubscribePending$
> 01 0 0 flow-11-2-stageFactory got ExposedPublisher
< 01 0 0 flow-11-2-stageFactory got ExposedPublisher
> 02 0 0 flow-11-2-stageFactory got SubscribePending$
< 02 0 0 flow-11-2-stageFactory got SubscribePending$
> 01 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got ExposedPublisher
< 01 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got ExposedPublisher
> 02 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got SubscribePending$
< 02 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got SubscribePending$
> 03 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got OnSubscribe
< 03 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got OnSubscribe
> 04 0 1 flow-11-9-map got OnSubscribe
< 04 0 1 flow-11-9-map got OnSubscribe
> 03 0 0 flow-11-8-mapAsync got OnSubscribe
< 03 0 0 flow-11-8-mapAsync got OnSubscribe
> 04 0 0 flow-11-8-mapAsync got RequestMore
< 04 0 1 flow-11-8-mapAsync got RequestMore
> 03 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got OnSubscribe
< 03 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got OnSubscribe
> 04 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got RequestMore
< 04 0 1 flow-11-7-collect-MultipartFormDataSpec.scala-73 got RequestMore
> 03 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got OnSubscribe
< 03 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got OnSubscribe
> 04 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got RequestMore
< 04 0 1 flow-11-6-collect-MultipartUnmarshallers.scala-91 got RequestMore
> 03 0 0 flow-11-5-concatAll got OnSubscribe
< 03 0 0 flow-11-5-concatAll got OnSubscribe
> 04 0 0 flow-11-5-concatAll got RequestMore
< 04 0 1 flow-11-5-concatAll got RequestMore
> 03 0 0 flow-11-4-map got OnSubscribe
< 03 0 0 flow-11-4-map got OnSubscribe
> 04 0 0 flow-11-4-map got RequestMore
< 04 0 1 flow-11-4-map got RequestMore
> 03 0 0 flow-11-3-splitWhen got OnSubscribe
< 03 0 0 flow-11-3-splitWhen got OnSubscribe
> 04 0 0 flow-11-3-splitWhen got RequestMore
< 04 0 1 flow-11-3-splitWhen got RequestMore
> 03 0 0 flow-11-2-stageFactory got OnSubscribe
< 03 0 0 flow-11-2-stageFactory got OnSubscribe
> 04 0 0 flow-11-2-stageFactory got RequestMore
< 04 0 1 flow-11-2-stageFactory got RequestMore
> 09 1 1 flow-10-1-prefixAndTail got SubstreamRequestMore
< 09 0 1 flow-10-1-prefixAndTail got SubstreamRequestMore
> 04 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got RequestMore
< 04 0 1 flow-11-1-collect-HttpMessageParser.scala-307 got RequestMore
> 05 0 1 flow-11-1-collect-HttpMessageParser.scala-307 got OnNext
flow-11-1-collect-HttpMessageParser.scala-307 is pushing ByteString(45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 45, 52, 51, 57, 49, 50, 101, 49, 99, 48, 100, 97, 50, 98, 57, 51, 99, 13, 10, 67, 111, 110, 116, 101, 110, 116, 45, 68, 105, 115, 112, 111, 115, 105, 116, 105, 111, 110, 58, 32, 102, 111, 114, 109, 45, 100, 97, 116, 97, 59, 32, 110, 97, 109, 101, 61, 34, 116, 104, 101, 66, 108, 111, 98, 34, 59, 32, 102, 105, 108, 101, 110, 97, 109, 101, 61, 34, 56, 51, 56, 57, 101, 49, 51, 57, 102, 55, 50, 100, 54, 51, 100, 54, 57, 48, 50, 57, 53, 51, 49, 51, 55, 48, 49, 54, 56, 50, 50, 55, 56, 56, 48, 46, 116, 109, 112, 34, 13, 10, 67, 111, 110, 116, 101, 110, 116, 45, 84, 121, 112, 101, 58, 32, 97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 47, 111, 99, 116, 101, 116, 45, 115, 116, 114, 101, 97, 109, 13, 10, 13, 10, -124, -51, 85, 55, -102, 4, -87, 117, 34, 109, -46, 9, -53, 110, 74, 1, 25, -102, 24, -52, -56, 56, 81, -106, -82, -35, -13, -4, -48, -22, -88, 44, -107, -81, -101, 112, 88, -106, -127, -63, 17, 19, 2, -75, 98, 38, 123, 110, 62, 121, 113, -10, -29, -60, 24, -77, -36, 71, -63, -67, 124, 100, 119, 55, 83, 54, 33, -41, 17, -125, -39, 78, -56, 110, -128, -119, 7, -31, -65, 51, 117, 23, -31, 16, 42, 2, 65, -94, -78, 40, 21, -108, -112, 40, -30, -46, 66, 78, 10, 105, -19, -26, 46, 25, -26, -106, -110, 90, 59, -73, 71, -48, 67, -13, -53, -45, -96, 3, -52, 5, -97, -115, 36, 102, -9, 18, -99, -53, 7, -26, -117, 57, 104, 31, 90, -115, -50, -22, 12, 103, -14, -44, 83, 87, -113, 11, -77, -57, -38, 94, 104, -53, 26, 21, 89, 8, 79, 86, -73, -68, -20, -114, -108, 78, -47, 33, -115, 96, 40, -25, -63, 9, 22, -12, 82, 8, 39, 8, -10, -90, -127, 106, 127, -110, 27, -117, -120, 27, 108, 30, -28, -23, 96, -83, -72, -95, -52, 33, 119, -34, 94, 10, 71, -124, 3, -89, 1, 48, 57, -14, -127, -23, -44, -52, 92, 53, -96, -107, -45, 90, -45, 2, 69, 124, 116, 57, 68, 115, -48, -121, -58, -80, 32, -55, -63, -14, 9, 115, 89, -128, -38, 124, 110, 117, 35, 90, 73, 33, 42, 113, -3, 96, 63, 73, 32, 34, 94, 15, -108, 88, -86, 55, -125, 111, -32, -110, -82, -37, -18, -70, 88, 60, -126, -35, -53, 13, 85, 67, -77, 10, 61, -67, 78, 85, 32, -8, 44, -11, -6, -49, 24, -79, -7, 38, -5, -2, 87, -26, -45, 122, 105, 121, -19, 107, -114, 52, 35, 63, 99, -108, -67, 83, -29, 88, 85, 32, 23, -71, 94, -106, 68, 81, -91, 119, -81, 67, 59, -35, -2, 117, -45, -38, -88, -53, -116, -53, -67, -123, 107, 55, -37, 2, -47, 44, 42, 79, 19, -63, 124, -117, 91, -95, -33, -98, -22, -73, -106, -86, 78, 6, -106, 92, 11, 13, -53, 75, 65, 82, -76, 64, 117, 45, 94, 12, 8, 16, -95, -45, 110, 27, -40, 70, 5, -11, -111, -118, 67, 74, -55, 45, -66, 3, -95, 97, -71, 83, 102, 59, 58, -8, 122, 89, 14, -70, 33, 101, -112, -71, -33, 78, -11, 32, 107, -19, -64, -47, -60, -52, 49, -38, 54, 43, 10, 17, -26, 77, -110, -34, 3, 126, 37, -33, -4, -16, 96, -53, 112, -74, 91, 40, -3, 122, 67, -123, -89, -50, 101, 121, 7, -75, 46, -90, 35, -77, 24, -4, -16, 79, 63, -50, -98, 99, -34, 28, -118, -115, 78, -87, 39, -83, -71, -125, 22, -112, -92, 71, -77, 121, -2, -49, -117, 106, -79, -39, -90, -2, -47, -115, -112, 112, 115, -113, 39, 67, 59, 48, 88, -29, -55, -41, 55, 88, -75, -5, -50, -128, -70, 59, -23, 127, -59, 119, -89, -68, -116, -36, 44, 54, 101, -44, 87, 23, -117, 66, 4, -27, 3, -105, -2, 44, 113, -126, 39, -41, 79, -37, -56, 70, 65, 99, 88, 7, 8, 6, 85, -125, 6, 117, -13, -121, -17, -99, 29, -97, -25, -48, -116, -67, 90, 19, -7, 19, -21, -126, -112, 88, -14, 12, 47, 63, 63, 91, 66, 45, -40, 57, -78, -113, 74, 36, -113, -114, 127, -49, 125, -6, 120, -123, -116, -9, 34, -18, 40, 41, -56, 1, -96, 104, -79, 66, 46, -105, 52, 87, -97, 56, -71, -112, -126, 44, 27, -73, 105, 7, -81, 9, 86, 104, 39, 122, -58)
< 05 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got OnNext
> 11 0 1 flow-7-1-splitWhen got SubstreamRequestMore
< 11 0 1 flow-7-1-splitWhen got SubstreamRequestMore
> 10 0 1 flow-10-1-prefixAndTail got SubstreamRequestMore
< 10 0 1 flow-10-1-prefixAndTail got SubstreamRequestMore
> 05 0 1 flow-11-2-stageFactory got OnNext
flow-11-2-stageFactory is pushing BodyPartStart(List(Content-Disposition: form-data; name=theBlob; filename=8389e139f72d63d69029531370168227880.tmp),<function1>)
< 05 0 0 flow-11-2-stageFactory got OnNext
> 06 0 0 flow-11-1-collect-HttpMessageParser.scala-307 got RequestMore
< 06 0 1 flow-11-1-collect-HttpMessageParser.scala-307 got RequestMore
> 05 0 1 flow-11-3-splitWhen got OnNext
< 05 0 0 flow-11-3-splitWhen got OnNext
> 06 0 0 flow-11-2-stageFactory got RequestMore
flow-11-2-stageFactory is pushing EntityPart(ByteString(-124, -51, 85, 55, -102, 4, -87, 117, 34, 109, -46, 9, -53, 110, 74, 1, 25, -102, 24, -52, -56, 56, 81, -106, -82, -35, -13, -4, -48, -22, -88, 44, -107, -81, -101, 112, 88, -106, -127, -63, 17, 19, 2, -75, 98, 38, 123, 110, 62, 121, 113, -10, -29, -60, 24, -77, -36, 71, -63, -67, 124, 100, 119, 55, 83, 54, 33, -41, 17, -125, -39, 78, -56, 110, -128, -119, 7, -31, -65, 51, 117, 23, -31, 16, 42, 2, 65, -94, -78, 40, 21, -108, -112, 40, -30, -46, 66, 78, 10, 105, -19, -26, 46, 25, -26, -106, -110, 90, 59, -73, 71, -48, 67, -13, -53, -45, -96, 3, -52, 5, -97, -115, 36, 102, -9, 18, -99, -53, 7, -26, -117, 57, 104, 31, 90, -115, -50, -22, 12, 103, -14, -44, 83, 87, -113, 11, -77, -57, -38, 94, 104, -53, 26, 21, 89, 8, 79, 86, -73, -68, -20, -114, -108, 78, -47, 33, -115, 96, 40, -25, -63, 9, 22, -12, 82, 8, 39, 8, -10, -90, -127, 106, 127, -110, 27, -117, -120, 27, 108, 30, -28, -23, 96, -83, -72, -95, -52, 33, 119, -34, 94, 10, 71, -124, 3, -89, 1, 48, 57, -14, -127, -23, -44, -52, 92, 53, -96, -107, -45, 90, -45, 2, 69, 124, 116, 57, 68, 115, -48, -121, -58, -80, 32, -55, -63, -14, 9, 115, 89, -128, -38, 124, 110, 117, 35, 90, 73, 33, 42, 113, -3, 96, 63, 73, 32, 34, 94, 15, -108, 88, -86, 55, -125, 111, -32, -110, -82, -37, -18, -70, 88, 60, -126, -35, -53, 13, 85, 67, -77, 10, 61, -67, 78, 85, 32, -8, 44, -11, -6, -49, 24, -79, -7, 38, -5, -2, 87, -26, -45, 122, 105, 121, -19, 107, -114, 52, 35, 63, 99, -108, -67, 83, -29, 88, 85, 32, 23, -71, 94, -106, 68, 81, -91, 119, -81, 67, 59, -35, -2, 117, -45, -38, -88, -53, -116, -53, -67, -123, 107, 55, -37, 2, -47, 44, 42, 79, 19, -63, 124, -117, 91, -95, -33, -98, -22, -73, -106, -86, 78, 6, -106, 92, 11, 13, -53, 75, 65, 82, -76, 64, 117, 45, 94, 12, 8, 16, -95, -45, 110, 27, -40, 70, 5, -11, -111, -118, 67, 74, -55, 45, -66, 3, -95, 97, -71, 83, 102, 59, 58, -8, 122, 89, 14, -70, 33, 101, -112, -71, -33, 78, -11, 32, 107, -19, -64, -47, -60, -52, 49, -38, 54, 43, 10, 17, -26, 77, -110, -34, 3, 126, 37, -33, -4, -16, 96, -53, 112, -74, 91, 40, -3, 122, 67, -123, -89, -50, 101, 121, 7, -75, 46, -90, 35, -77, 24, -4, -16, 79, 63, -50, -98, 99, -34, 28, -118, -115, 78, -87, 39, -83, -71, -125, 22, -112, -92, 71, -77, 121, -2, -49, -117, 106, -79, -39, -90, -2, -47, -115, -112, 112, 115, -113, 39, 67, 59, 48, 88, -29, -55, -41, 55, 88, -75, -5, -50, -128, -70, 59, -23, 127, -59, 119, -89, -68, -116, -36, 44, 54, 101, -44, 87, 23, -117, 66, 4, -27, 3, -105, -2, 44, 113, -126, 39, -41, 79, -37, -56, 70, 65, 99, 88, 7, 8, 6, 85, -125, 6, 117, -13, -121, -17, -99, 29, -97, -25, -48, -116, -67, 90, 19, -7, 19, -21, -126, -112, 88, -14, 12, 47, 63, 63, 91, 66, 45, -40, 57, -78))
< 06 0 0 flow-11-2-stageFactory got RequestMore
> 05 0 1 flow-11-4-map got OnNext
flow-11-4-map is pushing SourcePipe(PublisherSource(akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@2cfbdee5),List(Map(<function1>,OperationAttributes(List(Name(map)))), PrefixAndTail(1,OperationAttributes(List(Name(prefixAndTail))))),List(),OperationAttributes(List()))
< 05 0 0 flow-11-4-map got OnNext
> 06 0 0 flow-11-3-splitWhen got OnNext
< 06 1 0 flow-11-3-splitWhen got OnNext
> 07 1 0 flow-11-3-splitWhen got RequestMore
< 07 1 1 flow-11-3-splitWhen got RequestMore
> 05 0 1 flow-11-5-concatAll got OnNext
< 05 0 1 flow-11-5-concatAll got OnNext
> 06 0 0 flow-11-4-map got RequestMore
< 06 0 1 flow-11-4-map got RequestMore
> 08 1 1 flow-11-3-splitWhen got SubstreamSubscribe
< 08 1 1 flow-11-3-splitWhen got SubstreamSubscribe
> 01 0 0 flow-12-2-map got ExposedPublisher
< 01 0 0 flow-12-2-map got ExposedPublisher
> 02 0 0 flow-12-2-map got SubscribePending$
< 02 0 0 flow-12-2-map got SubscribePending$
> 01 0 0 flow-12-1-prefixAndTail got ExposedPublisher
< 01 0 0 flow-12-1-prefixAndTail got ExposedPublisher
> 02 0 0 flow-12-1-prefixAndTail got SubscribePending$
< 02 0 0 flow-12-1-prefixAndTail got SubscribePending$
> 03 0 0 flow-12-1-prefixAndTail got OnSubscribe
< 03 0 0 flow-12-1-prefixAndTail got OnSubscribe
> 06 0 1 flow-11-5-concatAll got SubstreamStreamOnSubscribe
< 06 0 1 flow-11-5-concatAll got SubstreamStreamOnSubscribe
> 03 0 0 flow-12-2-map got OnSubscribe
< 03 0 0 flow-12-2-map got OnSubscribe
> 04 0 0 flow-12-2-map got RequestMore
< 04 0 1 flow-12-2-map got RequestMore
> 09 1 1 flow-11-3-splitWhen got SubstreamRequestMore
< 09 1 1 flow-11-3-splitWhen got SubstreamRequestMore
> 04 0 0 flow-12-1-prefixAndTail got RequestMore
< 04 0 1 flow-12-1-prefixAndTail got RequestMore
> 05 0 1 flow-12-1-prefixAndTail got OnNext
< 05 0 0 flow-12-1-prefixAndTail got OnNext
> 10 1 1 flow-11-3-splitWhen got SubstreamRequestMore
< 10 0 1 flow-11-3-splitWhen got SubstreamRequestMore
> 05 0 1 flow-12-2-map got OnNext
flow-12-2-map is pushing (BodyPartStart(List(Content-Disposition: form-data; name=theBlob; filename=8389e139f72d63d69029531370168227880.tmp),<function1>),PublisherSource(akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@4be6a375))
< 05 0 0 flow-12-2-map got OnNext
> 06 0 0 flow-12-2-map got OnComplete$
< 06 0 0 flow-12-2-map got OnComplete$
> 07 0 0 flow-11-2-stageFactory got RequestMore
< 07 0 1 flow-11-2-stageFactory got RequestMore
> 06 0 0 flow-12-1-prefixAndTail got OnNext
< 06 1 0 flow-12-1-prefixAndTail got OnNext
> 07 1 0 flow-12-1-prefixAndTail got RequestMore
< 07 1 1 flow-12-1-prefixAndTail got RequestMore
> 07 0 1 flow-11-5-concatAll got SubstreamOnNext
< 07 0 0 flow-11-5-concatAll got SubstreamOnNext
> 08 0 0 flow-11-5-concatAll got SubstreamOnComplete
< 08 0 0 flow-11-5-concatAll got SubstreamOnComplete
> 05 0 1 flow-11-6-collect-MultipartUnmarshallers.scala-91 got OnNext
flow-11-6-collect-MultipartUnmarshallers.scala-91 is pushing FormData.BodyPart(theBlob, HttpEntity.IndefiniteLength(application/octet-stream,SourcePipe(PublisherSource(akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@4be6a375),List(Collect(<function1>,OperationAttributes(List(Name(collect-BodyPartParser.scala-175))))),List(),OperationAttributes(List()))), Map(filename -> 8389e139f72d63d69029531370168227880.tmp), List())
< 05 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got OnNext
> 09 0 0 flow-11-5-concatAll got RequestMore
< 09 0 1 flow-11-5-concatAll got RequestMore
> 05 0 1 flow-11-7-collect-MultipartFormDataSpec.scala-73 got OnNext
flow-11-7-collect-MultipartFormDataSpec.scala-73 is pushing BlobPart(8389e139f72d63d69029531370168227880.tmp,SourcePipe(PublisherSource(akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@4be6a375),List(Collect(<function1>,OperationAttributes(List(Name(collect-BodyPartParser.scala-175))))),List(),OperationAttributes(List())))
< 05 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got OnNext
> 06 0 0 flow-11-6-collect-MultipartUnmarshallers.scala-91 got RequestMore
< 06 0 1 flow-11-6-collect-MultipartUnmarshallers.scala-91 got RequestMore
> 05 0 1 flow-11-8-mapAsync got OnNext
< 05 0 1 flow-11-8-mapAsync got OnNext
> 06 0 0 flow-11-7-collect-MultipartFormDataSpec.scala-73 got RequestMore
< 06 0 1 flow-11-7-collect-MultipartFormDataSpec.scala-73 got RequestMore
> 08 1 1 flow-12-1-prefixAndTail got SubstreamSubscribe
< 08 1 1 flow-12-1-prefixAndTail got SubstreamSubscribe
> 01 0 0 flow-13-1-collect-BodyPartParser.scala-175 got ExposedPublisher
< 01 0 0 flow-13-1-collect-BodyPartParser.scala-175 got ExposedPublisher
> 02 0 0 flow-13-1-collect-BodyPartParser.scala-175 got SubscribePending$
< 02 0 0 flow-13-1-collect-BodyPartParser.scala-175 got SubscribePending$
> 03 0 0 flow-13-1-collect-BodyPartParser.scala-175 got OnSubscribe
< 03 0 0 flow-13-1-collect-BodyPartParser.scala-175 got OnSubscribe
> 01 0 0 flow-13-14-1-fold-stageFactory got ExposedPublisher
< 01 0 0 flow-13-14-1-fold-stageFactory got ExposedPublisher
> 02 0 0 flow-13-14-1-fold-stageFactory got SubscribePending$
< 02 0 0 flow-13-14-1-fold-stageFactory got SubscribePending$
> 03 0 0 flow-13-14-1-fold-stageFactory got OnSubscribe
< 03 0 0 flow-13-14-1-fold-stageFactory got OnSubscribe
> 04 0 0 flow-13-14-1-fold-stageFactory got RequestMore
< 04 0 1 flow-13-14-1-fold-stageFactory got RequestMore
> 09 1 1 flow-12-1-prefixAndTail got SubstreamRequestMore
< 09 0 1 flow-12-1-prefixAndTail got SubstreamRequestMore
> 04 0 0 flow-13-1-collect-BodyPartParser.scala-175 got RequestMore
< 04 0 1 flow-13-1-collect-BodyPartParser.scala-175 got RequestMore
> 05 0 1 flow-13-1-collect-BodyPartParser.scala-175 got OnNext
flow-13-1-collect-BodyPartParser.scala-175 is pushing ByteString(-124, -51, 85, 55, -102, 4, -87, 117, 34, 109, -46, 9, -53, 110, 74, 1, 25, -102, 24, -52, -56, 56, 81, -106, -82, -35, -13, -4, -48, -22, -88, 44, -107, -81, -101, 112, 88, -106, -127, -63, 17, 19, 2, -75, 98, 38, 123, 110, 62, 121, 113, -10, -29, -60, 24, -77, -36, 71, -63, -67, 124, 100, 119, 55, 83, 54, 33, -41, 17, -125, -39, 78, -56, 110, -128, -119, 7, -31, -65, 51, 117, 23, -31, 16, 42, 2, 65, -94, -78, 40, 21, -108, -112, 40, -30, -46, 66, 78, 10, 105, -19, -26, 46, 25, -26, -106, -110, 90, 59, -73, 71, -48, 67, -13, -53, -45, -96, 3, -52, 5, -97, -115, 36, 102, -9, 18, -99, -53, 7, -26, -117, 57, 104, 31, 90, -115, -50, -22, 12, 103, -14, -44, 83, 87, -113, 11, -77, -57, -38, 94, 104, -53, 26, 21, 89, 8, 79, 86, -73, -68, -20, -114, -108, 78, -47, 33, -115, 96, 40, -25, -63, 9, 22, -12, 82, 8, 39, 8, -10, -90, -127, 106, 127, -110, 27, -117, -120, 27, 108, 30, -28, -23, 96, -83, -72, -95, -52, 33, 119, -34, 94, 10, 71, -124, 3, -89, 1, 48, 57, -14, -127, -23, -44, -52, 92, 53, -96, -107, -45, 90, -45, 2, 69, 124, 116, 57, 68, 115, -48, -121, -58, -80, 32, -55, -63, -14, 9, 115, 89, -128, -38, 124, 110, 117, 35, 90, 73, 33, 42, 113, -3, 96, 63, 73, 32, 34, 94, 15, -108, 88, -86, 55, -125, 111, -32, -110, -82, -37, -18, -70, 88, 60, -126, -35, -53, 13, 85, 67, -77, 10, 61, -67, 78, 85, 32, -8, 44, -11, -6, -49, 24, -79, -7, 38, -5, -2, 87, -26, -45, 122, 105, 121, -19, 107, -114, 52, 35, 63, 99, -108, -67, 83, -29, 88, 85, 32, 23, -71, 94, -106, 68, 81, -91, 119, -81, 67, 59, -35, -2, 117, -45, -38, -88, -53, -116, -53, -67, -123, 107, 55, -37, 2, -47, 44, 42, 79, 19, -63, 124, -117, 91, -95, -33, -98, -22, -73, -106, -86, 78, 6, -106, 92, 11, 13, -53, 75, 65, 82, -76, 64, 117, 45, 94, 12, 8, 16, -95, -45, 110, 27, -40, 70, 5, -11, -111, -118, 67, 74, -55, 45, -66, 3, -95, 97, -71, 83, 102, 59, 58, -8, 122, 89, 14, -70, 33, 101, -112, -71, -33, 78, -11, 32, 107, -19, -64, -47, -60, -52, 49, -38, 54, 43, 10, 17, -26, 77, -110, -34, 3, 126, 37, -33, -4, -16, 96, -53, 112, -74, 91, 40, -3, 122, 67, -123, -89, -50, 101, 121, 7, -75, 46, -90, 35, -77, 24, -4, -16, 79, 63, -50, -98, 99, -34, 28, -118, -115, 78, -87, 39, -83, -71, -125, 22, -112, -92, 71, -77, 121, -2, -49, -117, 106, -79, -39, -90, -2, -47, -115, -112, 112, 115, -113, 39, 67, 59, 48, 88, -29, -55, -41, 55, 88, -75, -5, -50, -128, -70, 59, -23, 127, -59, 119, -89, -68, -116, -36, 44, 54, 101, -44, 87, 23, -117, 66, 4, -27, 3, -105, -2, 44, 113, -126, 39, -41, 79, -37, -56, 70, 65, 99, 88, 7, 8, 6, 85, -125, 6, 117, -13, -121, -17, -99, 29, -97, -25, -48, -116, -67, 90, 19, -7, 19, -21, -126, -112, 88, -14, 12, 47, 63, 63, 91, 66, 45, -40, 57, -78)
< 05 0 0 flow-13-1-collect-BodyPartParser.scala-175 got OnNext
> 11 0 1 flow-11-3-splitWhen got SubstreamRequestMore
< 11 0 1 flow-11-3-splitWhen got SubstreamRequestMore
> 10 0 1 flow-12-1-prefixAndTail got SubstreamRequestMore
< 10 0 1 flow-12-1-prefixAndTail got SubstreamRequestMore
> 05 0 1 flow-13-14-1-fold-stageFactory got OnNext
Total 577 after reading 1 elements: 577
< 05 0 1 flow-13-14-1-fold-stageFactory got OnNext
> 06 0 0 flow-13-1-collect-BodyPartParser.scala-175 got RequestMore
< 06 0 1 flow-13-1-collect-BodyPartParser.scala-175 got RequestMore
> 08 0 1 flow-9-1-rootParser-stageFactory got OnNext
Parsing part of size 1000
flow-9-1-rootParser-stageFactory is pushing EntityPart(ByteString(78, 45, -21, 79, -19, -22, 39, -104, -113, 59, -51, 120, -56, 27, 37, -103, -100, -81, 48, -87, 46, -31, -98, 59, -39, 76, 57, 75, 56, 15, -16, 110, -70, 53, -77, -105, 105, -72, 84, 78, 64, -115, -19, -63, 37, 77, 125, 14, -53, 94, -30, -77, -107, 125, 73, -107, 106, -47, 71, 68, -97, -64, -76, -85, -25, -5, 46, 12, 88, -109, -45, -84, 22, -60, 22, 66, 119, -105, 113, 17, -41, 30, -63, 77, -68, 126, 88, 92, 72, -105, 28, -21, -101, -11, 10, 28, -124, 0, -82, 30, -36, 99, 25, 47, 102, -85, 38, 57, -89, 31, 39, 105, -25, 51, 90, -55, 24, -101, 74, 69, 28, 18, -123, 48, -21, 111, 41, 80, 88, -79, -70, 33, -53, 45, 41, 104, 24, -36, 20, 103, 126, -39, 38, 17, 121, -111, 47, -97, -115, -109, -28, 94, -13, 125, 103, -58, 12, -15, 70, 76, 50, 14, 45, -51, -124, -9, -36, 127, -37, -119, -7, -112, 112, -85, 120, -74, 113, -45, -11, -26, 73, -33, 104, -122, -44, -64, -40, -93, 87, 126, 86, 10, -96, 16, 100, -66, 91, -125, 118, -85, -96, 87, -106, -2, 120, -113, 109, 60, 2, 87, 112, -33, 57, -61, 119, -16, -90, 120, 75, -124, 30, 99, 11, -12, 121, 96, -115, -12, -115, -99, 9, -69, 106, -51, -68, -1, 6, 67, 117, 58, 89, -99, -127, 107, 7, -73, 67, -92, 104, 111, 19, 102, -28, -94, 120, 109, 61, 31, -118, 85, -51, 0, 8, -112, 108, 73, 7, 98, -6, 87, -100, 121, 37, 98, -31, -113, -86, 57, -96, -2, -76, -17, -27, 14, -95, -51, -93, 72, 55, -44, 78, 39, 88, 19, 117, -96, 119, -122, 90, -2, -81, -72, 87, 120, -24, 15, -19, -9, -119, 119, 83, 45, -101, -77, -44, -125, 21, 104, -81, 79, 126, -61, -109, -106, -95, -2, 13, 117, -70, 17, -113, 44, 30, -15, 18, -21, 24, 124, 50, 113, 43, 100, -3, -75, -60, 103, 126, -114, 48, 90, -43, -67, -67, 57, 74, 52, -118, -29, 0, 44, -49, 73, 115, 72, 1, -49, -114, 56, 21, 21, -88, 110, 116, 41, -39, -18, -21, -4, -44, 65, -125, 21, 70, -60, -49, -106, -110, 115, 40, 45, -92, -9, 25, -63, 15, 51, 24, 43, 126, -7, -27, -21, 0, -124, 122, 14, -104, -126, -94, 65, -25, 109, -59, 101, 37, 9, 40, 33, -34, 45, 33, 68, -3, -101, 119, 29, -71, -44, 112, -19, -10, 124, -48, 67, 46, -18, -29, 55, -105, -13, 103, 126, -112, 42, 106, 29, 74, 35, 14, -20, 126, 29, -112, 36, -52, -13, 59, -49, 3, -110, -60, -98, 61, 70, -71, -111, -21, 10, -40, -29, -69, 19, 16, 14, -50, 83, 68, 16, 26, 31, -88, 90, 39, 99, -128, -104, 63, 107, -128, 57, 31, -36, -28, 24, 42, -116, 86, 21, 37, -38, 127, 3, 84, -119, 121, 44, -64, 7, 59, 14, -40, -1, -44, 9, -62, 4, -11, 24, 108, -123, -62, 37, 119, -95, 55, 40, -28, -72, 50, 118, 36, -124, 22, 84, 115, 83, -108, 117, 8, 42, 14, -48, -3, 54, -41, 42, -102, 104, -127, -105, 29, 88, -46, -100, -69, -40, 67, 48, -1, -22, 126, 14, -78, -46, -119, 89, 103, 63, -72, -50, 77, -31, 42, 8, -56, 45, -49, -104, 3, -37, 113, -78, -94, 12, 17, 127, -104, -6, 77, 37, 12, 116, -75, -51, -60, -77, -86, -36, 6, 112, 75, -76, 42, 26, -112, 9, -17, -62, 5, 51, -111, 12, -124, 21, -66, 95, -1, 117, 119, -125, 4, 109, -111, 93, 12, -35, -19, -72, -19, -50, -45, -33, -72, 37, -80, 2, -61, -74, -94, -60, 6, 70, 111, -112, 47, 9, 1, 35, 28, 25, -96, 116, 60, 120, -8, -33, -73, 111, 104, -104, -69, -75, 32, -40, -74, -87, -12, -116, -45, -86, 68, 120, -117, 13, -89, 96, 126, 114, 112, -67, 18, 96, -21, -44, -67, 39, 105, -22, -4, 104, -103, -84, 81, -1, -84, 121, -35, 36, -36, -15, 112, -50, 7, 23, 53, -103, -25, 87, 117, -59, 123, -88, 57, -68, 8, 42, 32, 78, -69, -97, 19, -62, -43, 115, 50, -29, 117, 54, -115, 124, 98, 43, 14, -53, -112, 77, 23, -98, -17, -75, 12, -84, -5, -16, 96, 115, 4, 5, -73, -32, -98, -43, -39, -39, 121, 16, 38, -80, -53, 88, 37, 64, 56, 120, 22, 14, -17, -68, 18, -1, -38, -97, -72, 99, 36, -72, -16, 21, 88, 117, -114, -87, -37, -105, 85, 24, -73, -57, -54, -87, 21, 121, -118, -46, 109, -35, 49, 78, -54, 119, -1, 21, 102, -100, -127, 19, 22, -76, 87, 42, 79, -113, 119, -116, 17, -93, 7, -112, 0, -125, -75, -41, 16, 9, -3, -51, 62, -95, -103, -60, 108, -121, -89, 7, -80, 25, -83, -100, -5, -81, -55, 103, -13, -20, 36, -79, -78, -19, 13, -121, -86, 83, 34, 104, -64, -52, 63, -100, -52, -51, 124, -116, 102, 106, -111, -84, 36, -26, -11, -89, 118, 7, 78, 26, 5, 42, 87, 36, 9, 26, 22, 18, 36, -23, 52, -120, -72, 90, 14, 125, -68, -77, 116, -38, -30, -113, -102, -40, -3, -73, 84, -15, 109, 44, 30, -118, -67, 106, 25, -62, -7, 6, 32, 43, 45, 26, -55, -45, -26, -98, -29, 116, 58, 100, 9, -2, 107, -37, 97, 11, 59, -91, 88, 20, 49, 37, 84, -128, 58, -48, 13, 123, -34, 62, 16, -18, -114, 96, -45, -66, 125, 88, 16, -34, -41, 56, 70, 95, -57, 39, -126, -45, 5, -86, 15, 91, 75, 10, -23, 66, 123, 7, -54, 70, 66, -122, 18, -27, 38, 91, 81, -102, 50, -101, 33, -106, 25, 74, 94, -22, -58, -65, -100, 110, 56, 40, 127, 81, 77, -117))
< 08 0 0 flow-9-1-rootParser-stageFactory got OnNext
> 12 0 [0, 1] flow-5-broadcast-bypassFanout got OnNext
< 12 1 [0, 1] flow-5-broadcast-bypassFanout got OnNext
> 09 0 0 flow-9-1-rootParser-stageFactory got OnNext
< 09 1 0 flow-9-1-rootParser-stageFactory got OnNext
@jrudolph
Copy link
Author

Btw. the lines were generated using these kinds of aroundReceive methods:

  var counter = 0
  override protected[akka] def aroundReceive(receive: Actor.Receive, msg: Any): Unit = {
    counter += 1
    println(f"> $counter%02d ${primaryInputs.bufferedElements} ${primaryOutputs.demandCount} ${self.path.name} got ${msg.getClass.getSimpleName}")
    super.aroundReceive(receive, msg)
    println(f"< $counter%02d ${primaryInputs.bufferedElements} ${primaryOutputs.demandCount} ${self.path.name} got ${msg.getClass.getSimpleName}")
  }

i.e

<entry/exit> <counter> <bufferedElements> <demand> <actor> <message>

@drewhk
Copy link

drewhk commented Dec 19, 2014

good one

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment