Class InterruptableInputStream

  • All Implemented Interfaces:
    Closeable, AutoCloseable, InputStreamWrapper

    public class InterruptableInputStream
    extends InputStream
    implements InputStreamWrapper
    Input stream wrapper that allows the underlying wrapped input stream to be interrupted. Every time a blocking stream operation is invoked on this class, the interrupt flag is checked first. If this flag is set, the underlying stream is closed and an IOException "Input Stream Interrupted" is thrown.

    Note: This hacky class does not really solve the problem of interrupting blocking Java input streams, as it cannot unblock a blocked read operation. It really just serves as a convenient way to interrupt streams before any potentially blocking operations.

    Author:
    James Murty