@DisplayName("requestChannel gathers metrics")
@Test
void requestChannel() {

  Mono<Payload> payload = Mono.just(DefaultPayload.create("test-metadata", "test-data"));
  when(delegate.requestChannel(payload)).thenReturn(Flux.empty());
  new MicrometerRSocket(delegate, meterRegistry, Tag.of("test-key", "test-value"))
      .requestChannel(payload)
      .as(StepVerifier::create)
      .verifyComplete();
  assertThat(findCounter("request.channel", SignalType.ON_COMPLETE).count()).isEqualTo(1);
}