Package com.amazonaws.kinesisvideo.stream.throttling

Class ThrottledInputStream

java.lang.Object

java.io.InputStream

com.amazonaws.kinesisvideo.stream.throttling.ThrottledInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class ThrottledInputStream
extends InputStream

Calls Throttler class each read operation so that Throttler measures and enforces the bandwidth it was configured to enforce

Constructor Summary

Constructors

Constructor	Description
ThrottledInputStream(InputStream unthrottledInputStream, Throttler throttler)

Method Summary

Modifier and Type	Method	Description
int	read()

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo

Methods inherited from class java.lang.Object

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

Constructor Detail

ThrottledInputStream

public ThrottledInputStream(InputStream unthrottledInputStream,
                            Throttler throttler)

Method Detail

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException