ch.randelshofer.io

Class SuspendableInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

ch.randelshofer.io.SuspendableInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class SuspendableInputStream
extends java.io.FilterInputStream

This input stream can be used to suspend, resume and abort a worker thread who is reading an input stream. The methods #suspend, #resume and #abort must by called from a different thread (the supervising thread).

Version:

1.0 1999-10-19

Author:

Werner Randelshofer, Hausmatt 10, CH-6405 Immensee, Switzerland

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
SuspendableInputStream(java.io.InputStream in)

Method Summary

Methods

Modifier and Type	Method and Description
void	abort()
boolean	isAborted()
boolean	isSuspended()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
void	resume()
void	suspend()

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

SuspendableInputStream

public SuspendableInputStream(java.io.InputStream in)

Method Detail

suspend

public void suspend()

resume

public void resume()

abort

public void abort()

isSuspended

public boolean isSuspended()

isAborted

public boolean isAborted()

read

public int read()
         throws java.io.IOException

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException

read

public int read(byte[] b)
         throws java.io.IOException

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException

read

public int read(byte[] b,
       int off,
       int len)
         throws java.io.IOException

Overrides:

read in class java.io.FilterInputStream

Throws:

java.io.IOException