@Test
public void testFireForget() {

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