io.pcp.parfait.io

Class ByteCountingOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

org.apache.commons.io.output.ProxyOutputStream

io.pcp.parfait.io.ByteCountingOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class ByteCountingOutputStream
extends org.apache.commons.io.output.ProxyOutputStream

Used to calculate the rate at which data is sent (downloaded) . When download outputstream wrapped in a ByteCountingOutputStream it can update the counters as byte or byte[] chunks are sent , allowing us to truly see the actual rate of transfers happening.

Field Summary

Fields inherited from class java.io.FilterOutputStream

out

Constructor Summary

Constructors

Constructor and Description
ByteCountingOutputStream(OutputStream out, Counter counter) Constructs a ByteCountingOutputStream

Method Summary

Modifier and Type	Method and Description
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class org.apache.commons.io.output.ProxyOutputStream

afterWrite, beforeWrite, close, flush, handleIOException

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteCountingOutputStream

public ByteCountingOutputStream(OutputStream out,
                                Counter counter)

Constructs a ByteCountingOutputStream

Parameters:

out - OutputStream to be wrapped

counter - PCP metric counter to be updated

Method Detail

write

public void write(byte[] b)
           throws IOException

Overrides:

write in class org.apache.commons.io.output.ProxyOutputStream

Throws:

IOException

See Also:

OutputStream.write(byte[])

write

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

Overrides:

write in class org.apache.commons.io.output.ProxyOutputStream

Throws:

IOException

See Also:

OutputStream.write(byte[], int, int)

write

public void write(int b)
           throws IOException

Overrides:

write in class org.apache.commons.io.output.ProxyOutputStream

Throws:

IOException

See Also:

OutputStream.write(int)