Package com.carrotsearch.procfork

Class TailInputStream

java.lang.Object
java.io.InputStream
com.carrotsearch.procfork.TailInputStream
All Implemented Interfaces:
java.io.Closeable, java.lang.AutoCloseable
public class TailInputStream
extends java.io.InputStream
An input stream that tails a file as new input appears there.

  • Constructor Summary

    Constructors 
    Constructor Description
    TailInputStream​(java.nio.file.Path file, java.util.function.Supplier<java.lang.Boolean> noMoreInput)  

  • Method Summary

    Modifier and Type Method Description
    void close()  
    boolean markSupported()  
    int read()  
    int read​(byte[] b)  
    int read​(byte[] b, int off, int len)  

    Methods inherited from class java.io.InputStream

    available, mark, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TailInputStream

      public TailInputStream​(java.nio.file.Path file, java.util.function.Supplier<java.lang.Boolean> noMoreInput) throws java.io.FileNotFoundException
      Throws:
      java.io.FileNotFoundException

  • Method Details

    • read

      public int read() throws java.io.IOException
      Specified by:
      read in class java.io.InputStream
      Throws:
      java.io.IOException

    • read

      public int read​(byte[] b, int off, int len) throws java.io.IOException
      Overrides:
      read in class java.io.InputStream
      Throws:
      java.io.IOException

    • read

      public int read​(byte[] b) throws java.io.IOException
      Overrides:
      read in class java.io.InputStream
      Throws:
      java.io.IOException

    • markSupported

      public boolean markSupported()
      Overrides:
      markSupported in class java.io.InputStream

    • close

      public void close() throws java.io.IOException
      Specified by:
      close in interface java.lang.AutoCloseable
      Specified by:
      close in interface java.io.Closeable
      Overrides:
      close in class java.io.InputStream
      Throws:
      java.io.IOException