Class AvroResponseMarshaller

java.lang.Object
org.apache.avro.grpc.AvroResponseMarshaller
All Implemented Interfaces:
io.grpc.MethodDescriptor.Marshaller<Object>

public class AvroResponseMarshaller extends Object implements io.grpc.MethodDescriptor.Marshaller<Object>
Marshaller for Avro RPC response.
  • Constructor Details

    • AvroResponseMarshaller

      public AvroResponseMarshaller(Protocol.Message message)
  • Method Details

    • stream

      public InputStream stream(Object value)
      Specified by:
      stream in interface io.grpc.MethodDescriptor.Marshaller<Object>
    • parse

      public Object parse(InputStream stream)
      Specified by:
      parse in interface io.grpc.MethodDescriptor.Marshaller<Object>