问如何使用reactor-test断言指标发布

EN

import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Metrics;
import io.micrometer.core.instrument.MockClock;
import io.micrometer.core.instrument.simple.SimpleConfig;
import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
import java.util.Set;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;

class ReactorTest {

  @Test
  void happyPathSuccess() {
    Set<MeterRegistry> registries = Metrics.globalRegistry.getRegistries();
    registries.forEach(Metrics.globalRegistry::remove);

    SimpleMeterRegistry simple = new SimpleMeterRegistry(SimpleConfig.DEFAULT, new MockClock());
    Metrics.addRegistry(simple);

    Mono.defer(() -> Mono.just("moooep moeeeep")).name("demo").metrics()
        .as(StepVerifier::create)
        .expectNext("moooep moeeeep")
        .expectComplete()
        .verify();

    long count = simple.get("demo.flow.duration")
        .tag("status", "completed")
        .tag("type", "Mono")
        .timer()
        .count();
    Assertions.assertEquals(1, count);
  }

}