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, net.thevpc.nuts.io.NContentMetadataProvider, net.thevpc.nuts.io.NInterruptible<InputStream>, net.thevpc.nuts.io.NNonBlockingInputStream

public class NNonBlockingInputStreamAdapter
extends FilterInputStream
implements net.thevpc.nuts.io.NNonBlockingInputStream, net.thevpc.nuts.io.NInterruptible<InputStream>, net.thevpc.nuts.io.NContentMetadataProvider

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
NNonBlockingInputStreamAdapter(InputStream base, net.thevpc.nuts.io.NContentMetadata md, net.thevpc.nuts.util.NMsg sourceName)

Method Summary

Modifier and Type	Method and Description
int	available()
InputStream	base()
void	close()
boolean	enqueue()
long	getLastReadTime()
net.thevpc.nuts.io.NContentMetadata	getMetaData()
net.thevpc.nuts.util.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,
                                      net.thevpc.nuts.io.NContentMetadata md,
                                      net.thevpc.nuts.util.NMsg sourceName)

Method Detail

getLastReadTime

public long getLastReadTime()

enqueue

public boolean enqueue()

base

public InputStream base()

Specified by:

base in interface net.thevpc.nuts.io.NInterruptible<InputStream>

interrupt

public void interrupt()
               throws net.thevpc.nuts.io.NInterruptException

Specified by:

interrupt in interface net.thevpc.nuts.io.NInterruptible<InputStream>

Throws:

net.thevpc.nuts.io.NInterruptException

read

public int read()
         throws IOException

Specified by:

read in interface net.thevpc.nuts.io.NNonBlockingInputStream

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Specified by:

read in interface net.thevpc.nuts.io.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 net.thevpc.nuts.io.NNonBlockingInputStream

Overrides:

read in class FilterInputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Specified by:

skip in interface net.thevpc.nuts.io.NNonBlockingInputStream

Overrides:

skip in class FilterInputStream

Throws:

IOException

available

public int available()
              throws IOException

Specified by:

available in interface net.thevpc.nuts.io.NNonBlockingInputStream

Overrides:

available in class FilterInputStream

Throws:

IOException

readNonBlocking

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

Specified by:

readNonBlocking in interface net.thevpc.nuts.io.NNonBlockingInputStream

Throws:

IOException

readNonBlocking

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

Specified by:

readNonBlocking in interface net.thevpc.nuts.io.NNonBlockingInputStream

Throws:

IOException

readNonBlocking

public int readNonBlocking(byte[] b)
                    throws IOException

Specified by:

readNonBlocking in interface net.thevpc.nuts.io.NNonBlockingInputStream

Throws:

IOException

readNonBlocking

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

Specified by:

readNonBlocking in interface net.thevpc.nuts.io.NNonBlockingInputStream

Throws:

IOException

noMoreBytes

public void noMoreBytes()

Specified by:

noMoreBytes in interface net.thevpc.nuts.io.NNonBlockingInputStream

hasMoreBytes

public boolean hasMoreBytes()

Specified by:

hasMoreBytes in interface net.thevpc.nuts.io.NNonBlockingInputStream

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface net.thevpc.nuts.io.NNonBlockingInputStream

Overrides:

close in class FilterInputStream

Throws:

IOException

getMetaData

public net.thevpc.nuts.io.NContentMetadata getMetaData()

Specified by:

getMetaData in interface net.thevpc.nuts.io.NContentMetadataProvider

getSourceName

public net.thevpc.nuts.util.NMsg getSourceName()

toString

public String toString()

Overrides:

toString in class Object