net.thevpc.nuts.runtime.standalone.io.util

Class NNonBlockingInputStreamAdapter

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

net.thevpc.nuts.runtime.standalone.io.util.NNonBlockingInputStreamAdapter

All Implemented Interfaces:

Closeable, AutoCloseable, NContentMetadataProvider, NInterruptible<InputStream>, NNonBlockingInputStream

public class NNonBlockingInputStreamAdapter
extends FilterInputStream
implements NNonBlockingInputStream, NInterruptible<InputStream>, NContentMetadataProvider

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
NNonBlockingInputStreamAdapter(InputStream base, NContentMetadata md, NMsg sourceName)

Method Summary

Modifier and Type	Method and Description
int	available()
InputStream	base()
void	close()
boolean	enqueue()
long	getLastReadTime()
NContentMetadata	getMetaData()
NMsg	getSourceName()
boolean	hasMoreBytes()
void	interrupt()
void	noMoreBytes()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
int	readNonBlocking(byte[] b)
int	readNonBlocking(byte[] b, int off, int len)
int	readNonBlocking(byte[] b, int off, int len, long timeout)
int	readNonBlocking(byte[] b, long timeout)
long	skip(long n)
String	toString()

Methods inherited from class java.io.FilterInputStream

mark, markSupported, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.thevpc.nuts.io.NNonBlockingInputStream

mark, markSupported, of, reset

Methods inherited from interface net.thevpc.nuts.io.NInterruptible

ofInputStream

Constructor Detail

NNonBlockingInputStreamAdapter

public NNonBlockingInputStreamAdapter(InputStream base,
                                      NContentMetadata md,
                                      NMsg sourceName)

Method Detail

getLastReadTime

public long getLastReadTime()

enqueue

public boolean enqueue()

base

public InputStream base()

Specified by:

base in interface NInterruptible<InputStream>

interrupt

public void interrupt()
               throws NInterruptException

Specified by:

interrupt in interface NInterruptible<InputStream>

Throws:

NInterruptException

read

public int read()
         throws IOException

Specified by:

read in interface NNonBlockingInputStream

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Specified by:

read in interface NNonBlockingInputStream

Overrides:

read in class FilterInputStream

Throws:

IOException

read

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

Specified by:

read in interface NNonBlockingInputStream

Overrides:

read in class FilterInputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Specified by:

skip in interface NNonBlockingInputStream

Overrides:

skip in class FilterInputStream

Throws:

IOException

available

public int available()
              throws IOException

Specified by:

available in interface NNonBlockingInputStream

Overrides:

available in class FilterInputStream

Throws:

IOException

readNonBlocking

public int readNonBlocking(byte[] b,
                           long timeout)
                    throws IOException

Specified by:

readNonBlocking in interface NNonBlockingInputStream

Throws:

IOException

readNonBlocking

public int readNonBlocking(byte[] b,
                           int off,
                           int len,
                           long timeout)
                    throws IOException

Specified by:

readNonBlocking in interface NNonBlockingInputStream

Throws:

IOException

readNonBlocking

public int readNonBlocking(byte[] b)
                    throws IOException

Specified by:

readNonBlocking in interface NNonBlockingInputStream

Throws:

IOException

readNonBlocking

public int readNonBlocking(byte[] b,
                           int off,
                           int len)
                    throws IOException

Specified by:

readNonBlocking in interface NNonBlockingInputStream

Throws:

IOException

noMoreBytes

public void noMoreBytes()

Specified by:

noMoreBytes in interface NNonBlockingInputStream

hasMoreBytes

public boolean hasMoreBytes()

Specified by:

hasMoreBytes in interface NNonBlockingInputStream

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface NNonBlockingInputStream

Overrides:

close in class FilterInputStream

Throws:

IOException

getMetaData

public NContentMetadata getMetaData()

Specified by:

getMetaData in interface NContentMetadataProvider

getSourceName

public NMsg getSourceName()

toString

public String toString()

Overrides:

toString in class Object