You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@commons.apache.org by gg...@apache.org on 2021/01/31 14:49:30 UTC
[commons-io] branch master updated: [IO-706] Add
TimestampedObserver.
This is an automated email from the ASF dual-hosted git repository.
ggregory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/commons-io.git
The following commit(s) were added to refs/heads/master by this push:
new 2ec5e0a [IO-706] Add TimestampedObserver.
2ec5e0a is described below
commit 2ec5e0acd3d3bee16d9df3f78aa6746f68928bcf
Author: Gary Gregory <ga...@gmail.com>
AuthorDate: Sun Jan 31 09:49:24 2021 -0500
[IO-706] Add TimestampedObserver.
Fat-fingered the class name previously.
---
...ampedObserver.java => TimestampedObserver.java} | 4 +--
...erverTest.java => TimestampedObserverTest.java} | 32 +++++++++++-----------
2 files changed, 18 insertions(+), 18 deletions(-)
diff --git a/src/main/java/org/apache/commons/io/input/TimetampedObserver.java b/src/main/java/org/apache/commons/io/input/TimestampedObserver.java
similarity index 94%
rename from src/main/java/org/apache/commons/io/input/TimetampedObserver.java
rename to src/main/java/org/apache/commons/io/input/TimestampedObserver.java
index 1123431..390e402 100644
--- a/src/main/java/org/apache/commons/io/input/TimetampedObserver.java
+++ b/src/main/java/org/apache/commons/io/input/TimestampedObserver.java
@@ -30,7 +30,7 @@ import org.apache.commons.io.input.ObservableInputStream.Observer;
* </p>
*
* <pre>
- * final TimetampedObserver timetampedObserver = new TimetampedObserver();
+ * final TimestampedObserver timetampedObserver = new TimestampedObserver();
* try (final ObservableInputStream inputStream = new ObservableInputStream(...),
* timetampedObserver)) {
* ...
@@ -40,7 +40,7 @@ import org.apache.commons.io.input.ObservableInputStream.Observer;
*
* @since 2.9.0
*/
-public class TimetampedObserver extends Observer {
+public class TimestampedObserver extends Observer {
private volatile Instant closeInstant;
private final Instant openInstant = Instant.now();
diff --git a/src/test/java/org/apache/commons/io/input/TimetampedObserverTest.java b/src/test/java/org/apache/commons/io/input/TimestampedObserverTest.java
similarity index 63%
rename from src/test/java/org/apache/commons/io/input/TimetampedObserverTest.java
rename to src/test/java/org/apache/commons/io/input/TimestampedObserverTest.java
index c5ed179..042563c 100644
--- a/src/test/java/org/apache/commons/io/input/TimetampedObserverTest.java
+++ b/src/test/java/org/apache/commons/io/input/TimestampedObserverTest.java
@@ -28,41 +28,41 @@ import org.apache.commons.io.IOUtils;
import org.junit.jupiter.api.Test;
/**
- * Tests {@link TimetampedObserver}.
+ * Tests {@link TimestampedObserver}.
*/
-public class TimetampedObserverTest {
+public class TimestampedObserverTest {
@Test
public void test() throws IOException, InterruptedException {
final Instant before = Instant.now();
Thread.sleep(20); // Some OS' clock granularity may be high.
- final TimetampedObserver timetampedObserver = new TimetampedObserver();
- assertTrue(timetampedObserver.getOpenInstant().isAfter(before));
- assertTrue(timetampedObserver.getOpenToNowDuration().toNanos() > 0);
- assertNull(timetampedObserver.getCloseInstant());
+ final TimestampedObserver timestampedObserver = new TimestampedObserver();
+ assertTrue(timestampedObserver.getOpenInstant().isAfter(before));
+ assertTrue(timestampedObserver.getOpenToNowDuration().toNanos() > 0);
+ assertNull(timestampedObserver.getCloseInstant());
final byte[] buffer = MessageDigestCalculatingInputStreamTest
.generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
try (final ObservableInputStream ois = new ObservableInputStream(new ByteArrayInputStream(buffer),
- timetampedObserver)) {
- assertTrue(timetampedObserver.getOpenInstant().isAfter(before));
- assertTrue(timetampedObserver.getOpenToNowDuration().toNanos() > 0);
+ timestampedObserver)) {
+ assertTrue(timestampedObserver.getOpenInstant().isAfter(before));
+ assertTrue(timestampedObserver.getOpenToNowDuration().toNanos() > 0);
}
- assertTrue(timetampedObserver.getOpenInstant().isAfter(before));
- assertTrue(timetampedObserver.getOpenToNowDuration().toNanos() > 0);
- assertTrue(timetampedObserver.getCloseInstant().isAfter(timetampedObserver.getOpenInstant()));
- assertTrue(timetampedObserver.getOpenToCloseDuration().toNanos() > 0);
+ assertTrue(timestampedObserver.getOpenInstant().isAfter(before));
+ assertTrue(timestampedObserver.getOpenToNowDuration().toNanos() > 0);
+ assertTrue(timestampedObserver.getCloseInstant().isAfter(timestampedObserver.getOpenInstant()));
+ assertTrue(timestampedObserver.getOpenToCloseDuration().toNanos() > 0);
}
@Test
public void testExample() throws IOException, InterruptedException {
- final TimetampedObserver timetampedObserver = new TimetampedObserver();
+ final TimestampedObserver timestampedObserver = new TimestampedObserver();
final byte[] buffer = MessageDigestCalculatingInputStreamTest
.generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
try (final ObservableInputStream ois = new ObservableInputStream(new ByteArrayInputStream(buffer),
- timetampedObserver)) {
+ timestampedObserver)) {
//
}
- System.out.printf("IO duration: %s%n", timetampedObserver.getOpenToCloseDuration());
+ System.out.printf("IO duration: %s%n", timestampedObserver.getOpenToCloseDuration());
}
}