com.amazonaws.kinesisvideo.stream.throttling

Class ThrottledInputStream

java.lang.Object

java.io.InputStream

com.amazonaws.kinesisvideo.stream.throttling.ThrottledInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ThrottledInputStream
extends java.io.InputStream

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

Constructor Summary

Constructors

Constructor and Description
ThrottledInputStream(java.io.InputStream unthrottledInputStream, Throttler throttler)

Method Summary

Modifier and Type	Method and Description
int	read()

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ThrottledInputStream

public ThrottledInputStream(java.io.InputStream unthrottledInputStream,
                            Throttler throttler)

Method Detail

read

public int read()
         throws java.io.IOException

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException