co.cask.cdap.data.stream.service.upload

Class AsyncChannelBufferInputStream

java.lang.Object

java.io.InputStream

co.cask.cdap.data.stream.service.upload.AsyncChannelBufferInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public final class AsyncChannelBufferInputStream
extends InputStream

An InputStream implementation that reads data from ChannelBuffer. It allows asynchronous update to add new buffer from this class to read from. The end of file is signaled by appending an empty ChannelBuffer to this stream.

Constructor Summary

Constructors

Constructor and Description
AsyncChannelBufferInputStream()

Method Summary

Methods

Modifier and Type	Method and Description
void	append(org.jboss.netty.buffer.ChannelBuffer buffer) Appends more content to be consumable through this stream.
void	close()
int	read()
int	read(byte[] b, int off, int len)

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncChannelBufferInputStream

public AsyncChannelBufferInputStream()

Method Detail

read

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

Overrides:

read in class InputStream

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

append

public void append(org.jboss.netty.buffer.ChannelBuffer buffer)
            throws InterruptedException,
                   IOException

Appends more content to be consumable through this stream. This method will block until the append is completed.

Throws:

InterruptedException - if the append operation is interrupted

IOException