A very simple RSocket client in Java

RSocketClient.java

package com.tpeczek.demo;

import io.rsocket.*;
import io.rsocket.transport.netty.client.TcpClientTransport;
import io.rsocket.util.DefaultPayload;

public class RSocketClient
{
    private static final String PAYLOAD = "[Demo Payload]";
    private static final int MAX_ECHOES = 10;

    public static void main( String[] args )
    {
        System.out.println("-- Demo.RSocket --");

        System.out.println("Connecting to RSocket server...");
        RSocket socket = RSocketFactory.connect()
            .transport(TcpClientTransport.create("127.0.0.1", 6000))
            .start()
            .block();

        System.out.println("Requesting stream...");
        System.out.println("    REQUEST PAYLOAD: " + PAYLOAD);
        socket.requestStream(DefaultPayload.create(PAYLOAD))
            .map(Payload::getDataUtf8)
            .doOnNext(payload -> System.out.println("    RESPONSE ON NEXT PAYLOAD: " + payload))
            .take(MAX_ECHOES)
            .then()
            .doFinally(signalType -> socket.dispose())
            .then()
            .block();
    }
}