@Test
public void testRequestResponse() {

  Payload incoming = Mockito.mock(Payload.class);
  Payload transformed = ByteBufPayload.create("transformed");
  Payload outgoing = ByteBufPayload.create("outgoing");
  RSocket mock = Mockito.mock(RSocket.class);
  Mockito.when(mock.requestResponse(Mockito.any(Payload.class))).thenReturn(Mono.just(outgoing));
  DefaultProteusSocket socket = new DefaultProteusSocket(payload -> transformed, () -> mock);
  Payload block = socket.requestResponse(incoming).block();
  Assert.assertTrue(block == outgoing);
  Mockito.verify(incoming, Mockito.times(0)).release();
}