[nifi] branch main updated: NIFI-8616 - Updated DelimitedInputStream to extend the FilterInputStream class. (#5203)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

markap14 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 7751305  NIFI-8616 - Updated DelimitedInputStream to extend the FilterInputStream class. (#5203)
7751305 is described below

commit 775130580ac34037ef2378d497fa02150976138f
Author: thenatog <38...@users.noreply.github.com>
AuthorDate: Wed Jul 7 18:36:58 2021 -0400

    NIFI-8616 - Updated DelimitedInputStream to extend the FilterInputStream class. (#5203)
---
 .../nifi/event/transport/netty/DelimitedInputStream.java     | 12 +++---------
 1 file changed, 3 insertions(+), 9 deletions(-)

diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/DelimitedInputStream.java b/nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/DelimitedInputStream.java
index 4f6a4b1..bc1e81e 100644
--- a/nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/DelimitedInputStream.java
+++ b/nifi-nar-bundles/nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/netty/DelimitedInputStream.java
@@ -16,28 +16,22 @@
  */
 package org.apache.nifi.event.transport.netty;
 
-import java.io.IOException;
+import java.io.FilterInputStream;
 import java.io.InputStream;
 
 /**
  * A delimited InputStream which retains a delimiter for later use
  */
-public class DelimitedInputStream extends InputStream {
+public class DelimitedInputStream extends FilterInputStream {
 
-    private final InputStream in;
     private final byte[] delimiter;
 
     public DelimitedInputStream(final InputStream in, final byte[] delimiter) {
-        this.in = in;
+        super(in);
         this.delimiter = delimiter;
     }
 
     public byte[] getDelimiter() {
         return delimiter;
     }
-
-    @Override
-    public int read() throws IOException {
-        return in.read();
-    }
 }