public static void main(String[] args) {

  CloseableChannel serverCloseable = RSocketFactory.receive()
      .acceptor((setup, sendingSocket) ->
          Mono.just(new AbstractRSocket() {

            @Override
            public Flux<Payload> requestChannel(Publisher<Payload> payloads) {
              return Flux.from(payloads).log().next()
                  .flatMapMany(in -> Flux.range(1, 3).map(i -> {
                    String data = in.getDataUtf8();
                    return DefaultPayload.create(data + "-" + i);
                  }));
            }
          }))
      .transport(TcpServerTransport.create("localhost", 7000))
      .start()
      .block();

  RSocket rsocket = RSocketFactory.connect()
      .dataMimeType(MimeTypeUtils.TEXT_PLAIN_VALUE)
      .transport(TcpClientTransport.create("localhost", 7000))
      .start()
      .block();

  Flux<Payload> payloadFlux = Flux.just(DefaultPayload.create("foo"), DefaultPayload.create("bar"));
  rsocket.requestChannel(payloadFlux).log().blockLast();

  rsocket.dispose();
  serverCloseable.dispose();
}