@Test public void intervalsCallUsesNoOpForDefault() { IntervalIterator iterator = mock(IntervalIterator.class); when(baseMetrics.intervalsWithDefault(eq(2000L), any(NoOpLatency.class))).thenReturn(iterator); IntervalIterator<PartitionedLatency<TimeoutableResult>> intervals = latencies.intervals(2000L); assertSame(iterator, intervals); }
@Override public IntervalIterator<PartitionedLatency<T>> intervals() { return rolling.intervalsWithDefault(noOpLatency); }
RollingLatency extends AbstractMetrics<T> implements WritableLatency<T>, Rolling<PartitionedLatency<T>> { @Override public IntervalIterator<PartitionedLatency<T>> intervals() { return rolling.intervalsWithDefault(noOpLatency); } }
RollingLatency extends AbstractMetrics<T> implements WritableLatency<T>, Rolling<PartitionedLatency<T>> { @Override public IntervalIterator<PartitionedLatency<T>> intervals() { return rolling.intervalsWithDefault(noOpLatency); } RollingLatency(Class<T> clazz, int buckets, long nanosPerBucket);  RollingLatency(Allocator<PartitionedLatency<T>> allocator, int buckets, long nanosPerBucket);  RollingLatency(RollingMetrics<PartitionedLatency<T>> rolling); }
RollingLatency extends AbstractMetrics<T> implements WritableLatency<T>, Rolling<PartitionedLatency<T>> { @Override public IntervalIterator<PartitionedLatency<T>> intervals() { return rolling.intervalsWithDefault(noOpLatency); } RollingLatency(Class<T> clazz, int buckets, long nanosPerBucket);  RollingLatency(Allocator<PartitionedLatency<T>> allocator, int buckets, long nanosPerBucket);  RollingLatency(RollingMetrics<PartitionedLatency<T>> rolling); @Override void write(T metric, long number, long nanoLatency, long nanoTime); @Override PartitionedLatency<T> current(); @Override PartitionedLatency<T> current(long nanoTime); @Override IntervalIterator<PartitionedLatency<T>> intervals(); @Override IntervalIterator<PartitionedLatency<T>> intervals(long nanoTime); }
RollingLatency extends AbstractMetrics<T> implements WritableLatency<T>, Rolling<PartitionedLatency<T>> { @Override public IntervalIterator<PartitionedLatency<T>> intervals() { return rolling.intervalsWithDefault(noOpLatency); } RollingLatency(Class<T> clazz, int buckets, long nanosPerBucket);  RollingLatency(Allocator<PartitionedLatency<T>> allocator, int buckets, long nanosPerBucket);  RollingLatency(RollingMetrics<PartitionedLatency<T>> rolling); @Override void write(T metric, long number, long nanoLatency, long nanoTime); @Override PartitionedLatency<T> current(); @Override PartitionedLatency<T> current(long nanoTime); @Override IntervalIterator<PartitionedLatency<T>> intervals(); @Override IntervalIterator<PartitionedLatency<T>> intervals(long nanoTime);  }