Closed yschimke closed 6 years ago
09:53:40.295 onSubscribe(FluxMap.MapSubscriber) 09:53:40.300 request(256) 09:53:40.337 onSubscribe(FluxPeek.PeekSubscriber) 09:53:40.339 request(32) 09:53:40.347 onNext(Frame => Stream ID: 1 Type: REQUEST_CHANNEL Initial Request N: 2147483647 Payload: data: "1" ) 09:53:40.352 onNext(Frame => Stream ID: 1 Type: REQUEST_N RequestN: 2147483647 Payload: ) 09:53:40.355 onNext(Frame => Stream ID: 1 Type: NEXT Payload: data: "2" ) 09:53:40.356 onNext(Frame => Stream ID: 1 Type: NEXT Payload: data: "3" ) 09:53:40.358 | onSubscribe([Fuseable] FluxJust.WeakScalarSubscription) 09:53:40.358 | onNext(Frame => Stream ID: 1 Type: COMPLETE Payload: ) 09:53:40.359 | onComplete() 09:53:40.359 onComplete() 09:53:40.359 request(1) 09:53:40.360 request(1) 09:53:40.360 onNext(Frame => Stream ID: 1 Type: NEXT Payload: data: "1" ) 09:53:40.361 request(1) 09:53:40.361 onNext(Frame => Stream ID: 1 Type: NEXT Payload: data: "2" ) 09:53:40.362 | onSubscribe([Fuseable] FluxJust.WeakScalarSubscription) 09:53:40.362 | onNext(Frame => Stream ID: 1 Type: CANCEL Payload: ) 09:53:40.362 | onComplete() 09:53:40.363 request(1)