sink ref with low watermark strategy

gistfile1.txt

[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