Class MarshalerInputStream
- java.lang.Object
-
- java.io.InputStream
-
- io.opentelemetry.exporter.internal.grpc.MarshalerInputStream
-
- All Implemented Interfaces:
io.grpc.Drainable
,io.grpc.KnownLength
,java.io.Closeable
,java.lang.AutoCloseable
public final class MarshalerInputStream extends java.io.InputStream implements io.grpc.Drainable, io.grpc.KnownLength
Adapter fromMarshaler
to gRPC types.This class is internal and is hence not for public use. Its APIs are unstable and can change at any time.
-
-
Constructor Summary
Constructors Constructor Description MarshalerInputStream(Marshaler message)
Creates a newMarshalerInputStream
.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
available()
int
drainTo(java.io.OutputStream target)
int
read()
int
read(byte[] b, int off, int len)
private static byte[]
toByteArray(Marshaler message)
-
-
-
Field Detail
-
message
@Nullable private Marshaler message
-
partial
@Nullable private java.io.ByteArrayInputStream partial
-
-
Constructor Detail
-
MarshalerInputStream
public MarshalerInputStream(Marshaler message)
Creates a newMarshalerInputStream
.
-
-
Method Detail
-
drainTo
public int drainTo(java.io.OutputStream target) throws java.io.IOException
- Specified by:
drainTo
in interfaceio.grpc.Drainable
- Throws:
java.io.IOException
-
read
public int read() throws java.io.IOException
- Specified by:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
read
public int read(byte[] b, int off, int len) throws java.io.IOException
- Overrides:
read
in classjava.io.InputStream
- Throws:
java.io.IOException
-
toByteArray
private static byte[] toByteArray(Marshaler message) throws java.io.IOException
- Throws:
java.io.IOException
-
available
public int available()
- Specified by:
available
in interfaceio.grpc.KnownLength
- Overrides:
available
in classjava.io.InputStream
-
-