com.exalead.papi.helper.http.replay

Class BlockingDataOutputStream

java.lang.Object

java.io.OutputStream

com.exalead.papi.helper.http.replay.BlockingDataOutputStream

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

public final class BlockingDataOutputStream
extends java.io.OutputStream
implements java.io.Closeable, java.lang.AutoCloseable, java.io.Flushable

Constructor Summary

Constructors

Constructor and Description
BlockingDataOutputStream()

Method Summary

Modifier and Type	Method and Description
void	close() Puts the queue in closed state.
void	copyTo(java.io.OutputStream outs) Copies content from the this queue into the output stream.
void	flush() Wake up any waiting reader thread.
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.io.OutputStream

write

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingDataOutputStream

public BlockingDataOutputStream()

Method Detail

write

public void write(int b)
           throws java.io.IOException

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

write

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

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

copyTo

public void copyTo(java.io.OutputStream outs)
            throws java.io.IOException

Copies content from the this queue into the output stream. Does not return unless:

• The queue is closed AND there is no more data
• An error occurred

Parameters:

outs - The output stream to write to. This stream is not closed by this method

Throws:

java.io.IOException

close

public void close()

Puts the queue in closed state. No more data can be written on the queue, and any waiting reader thread is woken up in order for the rest to be consumed.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.OutputStream

flush

public void flush()
           throws java.io.IOException

Wake up any waiting reader thread.

Specified by:

flush in interface java.io.Flushable

Overrides:

flush in class java.io.OutputStream

Throws:

java.io.IOException