Class RateLimitingInputStream
java.lang.Object
java.io.InputStream
java.io.FilterInputStream
org.elasticsearch.index.snapshots.blobstore.RateLimitingInputStream
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class RateLimitingInputStream
extends java.io.FilterInputStream
Rate limiting wrapper for InputStream
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
RateLimitingInputStream.Listener
-
Field Summary
Fields inherited from class java.io.FilterInputStream
in
-
Constructor Summary
Constructors Constructor Description RateLimitingInputStream(java.io.InputStream delegate, java.util.function.Supplier<org.apache.lucene.store.RateLimiter> rateLimiterSupplier, RateLimitingInputStream.Listener listener)
-
Method Summary
Methods inherited from class java.io.FilterInputStream
available, close, mark, markSupported, read, reset, skip
Methods inherited from class java.io.InputStream
nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
RateLimitingInputStream
public RateLimitingInputStream(java.io.InputStream delegate, java.util.function.Supplier<org.apache.lucene.store.RateLimiter> rateLimiterSupplier, RateLimitingInputStream.Listener listener)
-
-
Method Details
-
read
public int read() throws java.io.IOException- Overrides:
read
in classjava.io.FilterInputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b, int off, int len) throws java.io.IOException- Overrides:
read
in classjava.io.FilterInputStream
- Throws:
java.io.IOException
-