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

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