Created
January 4, 2018 12:47
-
-
Save ktoso/21fc4f7d168c712530ea624606679a78 to your computer and use it in GitHub Desktop.
sink ref with low watermark strategy
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[WARN] [01/04/2018 13:44:14.114] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Allocated receiver: Actor[akka://RemoteSystem/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.130] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Created SinkRef, pointing to remote Sink receiver: Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622], local worker: akka.stream.stage.GraphStageLogic$StageActor@2718ee31 | |
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(0,payload-1) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(1,payload-2) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(2,payload-3) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(3,payload-4) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.141] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(0,payload-1) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.141] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [17] (+13) | |
[WARN] [01/04/2018 13:44:14.142] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-1 | |
[WARN] [01/04/2018 13:44:14.143] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(1,payload-2) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.143] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-2 | |
[WARN] [01/04/2018 13:44:14.143] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(2,payload-3) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.143] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-3 | |
[WARN] [01/04/2018 13:44:14.143] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(3,payload-4) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.143] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-4 | |
[WARN] [01/04/2018 13:44:14.156] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(17)], consumable demand: [13] | |
[WARN] [01/04/2018 13:44:14.156] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(4,payload-5) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.156] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(5,payload-6) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.156] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(6,payload-7) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(7,payload-8) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(8,payload-9) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(9,payload-10) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(10,payload-11) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(11,payload-12) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(12,payload-13) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(13,payload-14) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(14,payload-15) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(15,payload-16) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.157] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(16,payload-17) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.161] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(4,payload-5) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.161] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-5 | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(5,payload-6) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-6 | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(6,payload-7) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-7 | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(7,payload-8) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-8 | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(8,payload-9) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.162] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-9 | |
[WARN] [01/04/2018 13:44:14.163] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(9,payload-10) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.163] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [26] (+9) | |
[WARN] [01/04/2018 13:44:14.163] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-10 | |
[WARN] [01/04/2018 13:44:14.163] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(10,payload-11) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.163] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-11 | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(26)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.163] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(11,payload-12) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(17,payload-18) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.163] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-12 | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(18,payload-19) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.164] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(12,payload-13) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(19,payload-20) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.164] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-13 | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(20,payload-21) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.164] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(13,payload-14) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(21,payload-22) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(22,payload-23) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.164] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-14 | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(23,payload-24) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.165] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(14,payload-15) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(24,payload-25) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.165] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-15 | |
[WARN] [01/04/2018 13:44:14.166] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(25,payload-26) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.166] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(15,payload-16) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.166] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-16 | |
[WARN] [01/04/2018 13:44:14.166] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(16,payload-17) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.166] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-17 | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(17,payload-18) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-18 | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(18,payload-19) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [35] (+9) | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-19 | |
[WARN] [01/04/2018 13:44:14.170] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(35)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(19,payload-20) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.170] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(26,payload-27) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-20 | |
[WARN] [01/04/2018 13:44:14.168] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(20,payload-21) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.170] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(27,payload-28) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.169] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-21 | |
[WARN] [01/04/2018 13:44:14.170] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(28,payload-29) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.169] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(21,payload-22) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.170] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(29,payload-30) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.169] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-22 | |
[WARN] [01/04/2018 13:44:14.171] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(30,payload-31) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.169] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(22,payload-23) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.171] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(31,payload-32) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.169] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-23 | |
[WARN] [01/04/2018 13:44:14.171] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(32,payload-33) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.169] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(23,payload-24) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.171] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(33,payload-34) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.169] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-24 | |
[WARN] [01/04/2018 13:44:14.170] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(24,payload-25) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.171] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(34,payload-35) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.170] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-25 | |
[WARN] [01/04/2018 13:44:14.173] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(44)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.170] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(25,payload-26) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.173] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(35,payload-36) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.170] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-26 | |
[WARN] [01/04/2018 13:44:14.173] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(36,payload-37) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.172] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(26,payload-27) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.173] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(37,payload-38) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.172] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-27 | |
[WARN] [01/04/2018 13:44:14.173] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(38,payload-39) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.172] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(27,payload-28) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.173] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(39,payload-40) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.172] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [44] (+9) | |
[WARN] [01/04/2018 13:44:14.172] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-28 | |
[WARN] [01/04/2018 13:44:14.174] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(40,payload-41) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.173] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(28,payload-29) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.174] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(41,payload-42) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.173] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-29 | |
[WARN] [01/04/2018 13:44:14.174] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(42,payload-43) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.175] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(29,payload-30) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.174] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(43,payload-44) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.175] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-30 | |
[WARN] [01/04/2018 13:44:14.175] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(30,payload-31) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.175] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-31 | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(31,payload-32) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-32 | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(32,payload-33) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-33 | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(33,payload-34) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(53)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-34 | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(44,payload-45) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(34,payload-35) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(45,payload-46) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.176] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-35 | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(46,payload-47) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.177] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(35,payload-36) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(47,payload-48) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.177] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-36 | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(48,payload-49) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.177] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(36,payload-37) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(49,payload-50) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.177] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [53] (+9) | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(50,payload-51) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.177] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-37 | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(51,payload-52) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(37,payload-38) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.180] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(52,payload-53) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-38 | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(38,payload-39) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-39 | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(39,payload-40) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-40 | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(40,payload-41) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.178] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-41 | |
[WARN] [01/04/2018 13:44:14.184] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(62)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.184] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(53,payload-54) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.179] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(41,payload-42) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.184] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(54,payload-55) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.179] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-42 | |
[WARN] [01/04/2018 13:44:14.184] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(55,payload-56) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.185] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(56,payload-57) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.179] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(42,payload-43) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.185] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(57,payload-58) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.179] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-43 | |
[WARN] [01/04/2018 13:44:14.179] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(43,payload-44) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.185] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(58,payload-59) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.179] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-44 | |
[WARN] [01/04/2018 13:44:14.185] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(59,payload-60) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(44,payload-45) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.185] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(60,payload-61) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-45 | |
[WARN] [01/04/2018 13:44:14.185] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(61,payload-62) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(45,payload-46) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [62] (+9) | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-46 | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(46,payload-47) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-47 | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(47,payload-48) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.188] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(71)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-48 | |
[WARN] [01/04/2018 13:44:14.188] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(62,payload-63) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.183] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(48,payload-49) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.188] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(63,payload-64) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.184] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-49 | |
[WARN] [01/04/2018 13:44:14.188] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(64,payload-65) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.184] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(49,payload-50) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.188] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(65,payload-66) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.184] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-50 | |
[WARN] [01/04/2018 13:44:14.188] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(66,payload-67) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.184] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(50,payload-51) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.188] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(67,payload-68) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.184] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-51 | |
[WARN] [01/04/2018 13:44:14.189] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(68,payload-69) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.184] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(51,payload-52) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.189] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(69,payload-70) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.184] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-52 | |
[WARN] [01/04/2018 13:44:14.189] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(70,payload-71) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.185] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(52,payload-53) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.185] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-53 | |
[WARN] [01/04/2018 13:44:14.186] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(53,payload-54) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.186] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-54 | |
[WARN] [01/04/2018 13:44:14.186] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(54,payload-55) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.186] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [71] (+9) | |
[WARN] [01/04/2018 13:44:14.186] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-55 | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(55,payload-56) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-56 | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(56,payload-57) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(80)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-25] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-57 | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(71,payload-72) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(57,payload-58) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(72,payload-73) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-58 | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(73,payload-74) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(58,payload-59) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(74,payload-75) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(75,payload-76) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.187] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-59 | |
[WARN] [01/04/2018 13:44:14.188] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(59,payload-60) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(76,payload-77) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.188] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-60 | |
[WARN] [01/04/2018 13:44:14.192] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(77,payload-78) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.188] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(60,payload-61) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.193] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(78,payload-79) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.188] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-61 | |
[WARN] [01/04/2018 13:44:14.193] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(79,payload-80) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.188] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(61,payload-62) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.188] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-62 | |
[WARN] [01/04/2018 13:44:14.190] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(62,payload-63) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.190] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-63 | |
[WARN] [01/04/2018 13:44:14.195] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(89)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.190] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(63,payload-64) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.190] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [80] (+9) | |
[WARN] [01/04/2018 13:44:14.190] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-64 | |
[WARN] [01/04/2018 13:44:14.195] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(80,payload-81) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(64,payload-65) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.195] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(81,payload-82) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-65 | |
[WARN] [01/04/2018 13:44:14.195] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(82,payload-83) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(65,payload-66) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.196] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(83,payload-84) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-22] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-66 | |
[WARN] [01/04/2018 13:44:14.196] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(84,payload-85) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(66,payload-67) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.196] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(85,payload-86) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-67 | |
[WARN] [01/04/2018 13:44:14.196] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(86,payload-87) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(67,payload-68) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.196] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(87,payload-88) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.191] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-68 | |
[WARN] [01/04/2018 13:44:14.196] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(88,payload-89) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.192] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(68,payload-69) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.192] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-69 | |
[WARN] [01/04/2018 13:44:14.192] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(69,payload-70) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.192] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-70 | |
[WARN] [01/04/2018 13:44:14.192] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(70,payload-71) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.192] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-71 | |
[WARN] [01/04/2018 13:44:14.193] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(71,payload-72) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.199] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(98)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.193] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-72 | |
[WARN] [01/04/2018 13:44:14.199] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(89,payload-90) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.194] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(72,payload-73) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.199] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(90,payload-91) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.194] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [89] (+9) | |
[WARN] [01/04/2018 13:44:14.199] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(91,payload-92) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.194] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-73 | |
[WARN] [01/04/2018 13:44:14.199] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(92,payload-93) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.194] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(73,payload-74) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.200] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(93,payload-94) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.194] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-74 | |
[WARN] [01/04/2018 13:44:14.200] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(94,payload-95) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.195] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(74,payload-75) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.200] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(95,payload-96) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.195] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-75 | |
[WARN] [01/04/2018 13:44:14.200] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(96,payload-97) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.195] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(75,payload-76) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.200] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(97,payload-98) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.195] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-76 | |
[WARN] [01/04/2018 13:44:14.195] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(76,payload-77) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.196] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-77 | |
[WARN] [01/04/2018 13:44:14.196] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(77,payload-78) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.196] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-78 | |
[WARN] [01/04/2018 13:44:14.196] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(78,payload-79) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.196] [RemoteSystem-akka.test.stream-dispatcher-20] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-79 | |
[WARN] [01/04/2018 13:44:14.196] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(79,payload-80) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.196] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-80 | |
[WARN] [01/04/2018 13:44:14.203] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Received cumulative demand [CumulativeDemand(107)], consumable demand: [9] | |
[WARN] [01/04/2018 13:44:14.203] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(98,payload-99) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.204] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(99,payload-100) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622] | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(80,payload-81) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-81 | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(81,payload-82) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [98] (+9) | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-82 | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(82,payload-83) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-83 | |
[WARN] [01/04/2018 13:44:14.198] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(83,payload-84) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.199] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-84 | |
[WARN] [01/04/2018 13:44:14.199] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(84,payload-85) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.199] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-85 | |
[WARN] [01/04/2018 13:44:14.199] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(85,payload-86) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.199] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-86 | |
[WARN] [01/04/2018 13:44:14.200] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(86,payload-87) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.200] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-87 | |
[WARN] [01/04/2018 13:44:14.200] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(87,payload-88) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.200] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-88 | |
[WARN] [01/04/2018 13:44:14.200] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(88,payload-89) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.200] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-89 | |
[WARN] [01/04/2018 13:44:14.201] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(89,payload-90) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.201] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-90 | |
[WARN] [01/04/2018 13:44:14.201] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(90,payload-91) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.201] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [107] (+9) | |
[WARN] [01/04/2018 13:44:14.201] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-91 | |
[WARN] [01/04/2018 13:44:14.202] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(91,payload-92) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.202] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-92 | |
[WARN] [01/04/2018 13:44:14.202] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(92,payload-93) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.202] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-93 | |
[WARN] [01/04/2018 13:44:14.202] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(93,payload-94) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.202] [RemoteSystem-akka.test.stream-dispatcher-26] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-94 | |
[WARN] [01/04/2018 13:44:14.203] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(94,payload-95) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.203] [RemoteSystem-akka.test.stream-dispatcher-24] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-95 | |
[WARN] [01/04/2018 13:44:14.203] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(95,payload-96) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.203] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-96 | |
[WARN] [01/04/2018 13:44:14.204] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(96,payload-97) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.204] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-97 | |
[WARN] [01/04/2018 13:44:14.205] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(97,payload-98) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.205] [RemoteSystem-akka.test.stream-dispatcher-23] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-98 | |
[WARN] [01/04/2018 13:44:14.210] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(98,payload-99) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.210] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-99 | |
[WARN] [01/04/2018 13:44:14.210] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Received seq SequencedOnNext(99,payload-100) from Actor[akka.tcp://StreamRefsSpec@localhost:50506/user/StreamSupervisor-0/$$a-SinkRefActor-0#-1539735857] | |
[WARN] [01/04/2018 13:44:14.210] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] [SinkRefTargetSource-0] Demanding until [116] (+9) | |
[WARN] [01/04/2018 13:44:14.210] [RemoteSystem-akka.test.stream-dispatcher-19] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] PUSHING DIRECTLY payload-100 | |
[INFO] [01/04/2018 13:44:14.243] [RemoteSystem-akka.remote.default-remote-dispatcher-6] [akka.tcp://RemoteSystem@localhost:50507/system/remoting-terminator] Shutting down remote daemon. | |
[INFO] [01/04/2018 13:44:14.244] [RemoteSystem-akka.remote.default-remote-dispatcher-6] [akka.tcp://RemoteSystem@localhost:50507/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports. | |
Coroner Thread Count started at 44, ended at 8, peaked at 56 in akka.stream.remote.StreamRefsSpec | |
[ERROR] [01/04/2018 13:44:14.275] [StreamRefsSpec-akka.remote.default-remote-dispatcher-6] [akka.tcp://StreamRefsSpec@localhost:50506/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FRemoteSystem%40localhost%3A50507-0/endpointWriter] AssociationError [akka.tcp://StreamRefsSpec@localhost:50506] -> [akka.tcp://RemoteSystem@localhost:50507]: Error [Shut down address: akka.tcp://RemoteSystem@localhost:50507] [ | |
akka.remote.ShutDownAssociation: Shut down address: akka.tcp://RemoteSystem@localhost:50507 | |
Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down. | |
] | |
[INFO] [01/04/2018 13:44:14.282] [RemoteSystem-akka.actor.default-dispatcher-4] [akka.remote.Remoting] Remoting shut down | |
[INFO] [01/04/2018 13:44:14.282] [RemoteSystem-akka.remote.default-remote-dispatcher-7] [akka.tcp://RemoteSystem@localhost:50507/system/remoting-terminator] Remoting shut down. | |
[INFO] [01/04/2018 13:44:14.296] [StreamRefsSpec-akka.remote.default-remote-dispatcher-15] [akka.tcp://StreamRefsSpec@localhost:50506/system/remoting-terminator] Shutting down remote daemon. | |
[INFO] [01/04/2018 13:44:14.296] [StreamRefsSpec-akka.remote.default-remote-dispatcher-15] [akka.tcp://StreamRefsSpec@localhost:50506/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports. | |
[INFO] [01/04/2018 13:44:14.300] [StreamRefsSpec-akka.actor.default-dispatcher-5] [akka.remote.Remoting] Remoting shut down | |
[INFO] [01/04/2018 13:44:14.300] [StreamRefsSpec-akka.remote.default-remote-dispatcher-6] [akka.tcp://StreamRefsSpec@localhost:50506/system/remoting-terminator] Remoting shut down. | |
[info] - must receive hundreds of elements via remoting (163 milliseconds) | |
[info] ScalaTest | |
[info] Run completed in 1 second, 848 milliseconds. | |
[info] Total number of tests run: 1 | |
[info] Suites: completed 1, aborted 0 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment