@Test
public void checkName() {

  final TestRequesterResponderSupport activeStreams = TestRequesterResponderSupport.client();
  final LeaksTrackingByteBufAllocator allocator = activeStreams.getAllocator();
  final Payload payload = TestRequesterResponderSupport.genericPayload(allocator);
  final RequestStreamRequesterFlux requestStreamRequesterFlux =
      new RequestStreamRequesterFlux(payload, activeStreams);
  Assertions.assertThat(Scannable.from(requestStreamRequesterFlux).name())
      .isEqualTo("source(RequestStreamFlux)");
  requestStreamRequesterFlux.cancel();
  allocator.assertHasNoLeaks();
}