Package io.deephaven.client.impl

Class BarrageSubscriptionImpl.BarrageDataMarshaller

java.lang.Object

io.deephaven.client.impl.BarrageSubscriptionImpl.BarrageDataMarshaller

All Implemented Interfaces:

io.grpc.MethodDescriptor.Marshaller<BarrageMessage>

Enclosing class:

BarrageSubscriptionImpl

public static class BarrageSubscriptionImpl.BarrageDataMarshaller
extends Object
implements io.grpc.MethodDescriptor.Marshaller<BarrageMessage>

Constructor Summary

Constructors

Constructor	Description
BarrageDataMarshaller(BarrageSubscriptionOptions options, ChunkType[] columnChunkTypes, Class<?>[] columnTypes, Class<?>[] componentTypes, StreamReader streamReader)

Method Summary

Modifier and Type	Method	Description
BarrageMessage	parse(InputStream stream)
InputStream	stream(BarrageMessage value)

Methods inherited from class java.lang.Object

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

Constructor Details

BarrageDataMarshaller

public BarrageDataMarshaller(BarrageSubscriptionOptions options,
 ChunkType[] columnChunkTypes,
 Class<?>[] columnTypes,
 Class<?>[] componentTypes,
 StreamReader streamReader)

Method Details

stream

public InputStream stream(BarrageMessage value)

Specified by:

stream in interface io.grpc.MethodDescriptor.Marshaller<BarrageMessage>

parse

public BarrageMessage parse(InputStream stream)

Specified by:

parse in interface io.grpc.MethodDescriptor.Marshaller<BarrageMessage>