Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
nastassia-dailidava committed Oct 19, 2024
1 parent 20f22b7 commit 025872c
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -98,9 +98,9 @@ class ReactorUtilsTest {
// then
assertThat(received.await(2, TimeUnit.SECONDS)).isTrue()

val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_METRIC)
val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_TOTAL_METRIC)
.tags(Tags.of(METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, "latest-before")).counter()?.count()
val discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_METRIC)
val discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_TOTAL_METRIC)
.tags(Tags.of(METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, "latest")).counter()?.count()

/**
Expand Down

0 comments on commit 025872c

Please sign in to comment.