Class MarshalerInputStream

java.lang.Object

java.io.InputStream

io.opentelemetry.exporter.internal.grpc.MarshalerInputStream

All Implemented Interfaces:

io.grpc.Drainable, io.grpc.KnownLength, Closeable, AutoCloseable

public final class MarshalerInputStream
extends InputStream
implements io.grpc.Drainable, io.grpc.KnownLength

Adapter from Marshaler to gRPC types.

This class is internal and is hence not for public use. Its APIs are unstable and can change at any time.

Field Summary

Fields

Modifier and Type	Field	Description
private Marshaler	message
private ByteArrayInputStream	partial

Constructor Summary

Constructors

Constructor	Description
MarshalerInputStream(Marshaler message)	Creates a new MarshalerInputStream.

Method Summary

Modifier and Type	Method	Description
int	available()
int	drainTo(OutputStream target)
int	read()
int	read(byte[] b, int off, int len)
private static byte[]	toByteArray(Marshaler message)

Methods inherited from class InputStream

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

Methods inherited from class Object

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

Field Details

message

@Nullable
private Marshaler message

partial

@Nullable
private ByteArrayInputStream partial

Constructor Details

MarshalerInputStream

public MarshalerInputStream(Marshaler message)

Creates a new MarshalerInputStream.

Method Details

drainTo

public int drainTo(OutputStream target)
            throws IOException

Specified by:

drainTo in interface io.grpc.Drainable

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

toByteArray

private static byte[] toByteArray(Marshaler message)
                           throws IOException

Throws:

IOException

available

public int available()

Specified by:

available in interface io.grpc.KnownLength

Overrides:

available in class InputStream