[0.5.x] stream and subscription not responding #211
Description
Run against TcpPongServer
package io.reactivesocket.transport.tcp;
import io.reactivesocket.Payload;
import io.reactivesocket.ReactiveSocket;
import io.reactivesocket.client.ReactiveSocketClient;
import io.reactivesocket.frame.ByteBufferUtil;
import io.reactivesocket.transport.tcp.client.TcpTransportClient;
import io.reactivesocket.util.PayloadImpl;
import io.reactivex.Flowable;
import org.reactivestreams.Publisher;
import org.slf4j.event.Level;
import java.net.InetSocketAddress;
import static io.reactivesocket.client.KeepAliveProvider.never;
import static io.reactivesocket.client.SetupProvider.keepAlive;
public class TcpPongClient {
public static void main(String[] args) {
Publisher<? extends ReactiveSocket> c = ReactiveSocketClient.create(TcpTransportClient.create(new InetSocketAddress(7878)).logReactiveSocketFrames("rs", Level.WARN),
keepAlive(never()).disableLease()).connect();
ReactiveSocket client = Flowable.fromPublisher(c).blockingFirst();
Publisher<Payload> x = client.requestStream(new PayloadImpl("Hello"));
Payload response = Flowable.fromPublisher(x).blockingFirst();
System.out.println(response);
}
}
Output
28 Dec 2016 09:40:09,986 INFO [main] (Frame.java:61) - Creating thread pooled named io.reactivesocket.frame.UnpooledFrame
28 Dec 2016 09:40:10,778 WARN [rxnetty-nio-eventloop-1-1] (ReactiveSocketFrameLogger.java:57) - [id: 0x56236355, L:/192.168.0.21:52919 - R:0.0.0.0/0.0.0.0:7878] Writing frame: Frame[0] => Stream ID: 0 Type: SETUP Version: 0 keep-alive interval: 2147483647 max lifetime: 2147483645 metadata mime type: application/x.reactivesocket.meta+cbor data mime type: application/binary Payload:
28 Dec 2016 09:40:10,952 WARN [rxnetty-nio-eventloop-1-1] (ReactiveSocketFrameLogger.java:57) - [id: 0x56236355, L:/192.168.0.21:52919 - R:0.0.0.0/0.0.0.0:7878] Writing frame: Frame[0] => Stream ID: 3 Type: REQUEST_N RequestN: 2147483647 Payload: