stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/ServerStats.java [88:96]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void recordLatency(boolean success, long latencyMicros) {
        completedLatencyMicros.ifPresent(latencyLogger -> {
            if (success) {
                latencyLogger.registerSuccessfulEvent(latencyMicros, TimeUnit.MICROSECONDS);
            } else {
                latencyLogger.registerFailedEvent(latencyMicros, TimeUnit.MICROSECONDS);
            }
        });
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/ClientStats.java [88:96]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void recordLatency(boolean success, long latencyMicros) {
        completedLatencyMicros.ifPresent(latencyLogger -> {
            if (success) {
                latencyLogger.registerSuccessfulEvent(latencyMicros, TimeUnit.MICROSECONDS);
            } else {
                latencyLogger.registerFailedEvent(latencyMicros, TimeUnit.MICROSECONDS);
            }
        });
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -