@Test
public void simpleOnDiscardRequestChannelTest() {

  AssertSubscriber<Payload> assertSubscriber = AssertSubscriber.create(1);
  TestPublisher<Payload> testPublisher = TestPublisher.create();
  Flux<Payload> payloadFlux = rule.socket.requestChannel(testPublisher);
  payloadFlux.subscribe(assertSubscriber);
  testPublisher.next(
      ByteBufPayload.create("d", "m"),
      ByteBufPayload.create("d1", "m1"),
      ByteBufPayload.create("d2", "m2"));
  assertSubscriber.cancel();
  Assertions.assertThat(rule.connection.getSent()).allMatch(ByteBuf::release);
  rule.assertHasNoLeaks();
}