[commons-io] branch master updated: [IO-706] Add TimestampedObserver.

[ggregory]

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 <gardgreg...@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());
     }
 
 }