Package akka.stream.impl.io
Class InputStreamAdapter
- java.lang.Object
-
- java.io.InputStream
-
- akka.stream.impl.io.InputStreamAdapter
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class InputStreamAdapter extends java.io.InputStream
INTERNAL API InputStreamAdapter that interacts with InputStreamSinkStage
-
-
Constructor Summary
Constructors Constructor Description InputStreamAdapter(java.util.concurrent.BlockingQueue<InputStreamSinkStage.StreamToAdapterMessage> sharedBuffer, scala.Function1<InputStreamSinkStage.AdapterToStageMessage,scala.runtime.BoxedUnit> sendToStage, scala.concurrent.duration.FiniteDuration readTimeout)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
scala.Option<ByteString>
detachedChunk()
void
detachedChunk_$eq(scala.Option<ByteString> x$1)
java.util.concurrent.atomic.AtomicBoolean
isActive()
boolean
isInitialized()
void
isInitialized_$eq(boolean x$1)
boolean
isStageAlive()
void
isStageAlive_$eq(boolean x$1)
int
read()
int
read(byte[] a)
int
read(byte[] a, int begin, int length)
java.io.IOException
subscriberClosedException()
-
-
-
Constructor Detail
-
InputStreamAdapter
public InputStreamAdapter(java.util.concurrent.BlockingQueue<InputStreamSinkStage.StreamToAdapterMessage> sharedBuffer, scala.Function1<InputStreamSinkStage.AdapterToStageMessage,scala.runtime.BoxedUnit> sendToStage, scala.concurrent.duration.FiniteDuration readTimeout)
-
-
Method Detail
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classjava.io.InputStream
- Throws:
java.io.IOException
-
detachedChunk
public scala.Option<ByteString> detachedChunk()
-
detachedChunk_$eq
public void detachedChunk_$eq(scala.Option<ByteString> x$1)
-
isActive
public java.util.concurrent.atomic.AtomicBoolean isActive()
-
isInitialized
public boolean isInitialized()
-
isInitialized_$eq
public void isInitialized_$eq(boolean x$1)
-
isStageAlive
public boolean isStageAlive()
-
isStageAlive_$eq
public void isStageAlive_$eq(boolean x$1)
-
read
public int read() throws java.io.IOException
- Specified by:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] a) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] a, int begin, int length) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
subscriberClosedException
public java.io.IOException subscriberClosedException()
-
-