MCPcopy Create free account
hub / github.com/apache/kafka / MockTime

Class MockTime

clients/src/test/java/org/apache/kafka/common/utils/MockTime.java:20–43  ·  view source on GitHub ↗

A clock that you can manually advance by calling sleep

Source from the content-addressed store, hash-verified

18 * A clock that you can manually advance by calling sleep
19 */
20public class MockTime implements Time {
21
22 private long nanos = 0;
23
24 public MockTime() {
25 this.nanos = System.nanoTime();
26 }
27
28 @Override
29 public long milliseconds() {
30 return TimeUnit.MILLISECONDS.convert(this.nanos, TimeUnit.NANOSECONDS);
31 }
32
33 @Override
34 public long nanoseconds() {
35 return nanos;
36 }
37
38 @Override
39 public void sleep(long ms) {
40 this.nanos += TimeUnit.NANOSECONDS.convert(ms, TimeUnit.MILLISECONDS);
41 }
42
43}

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected