// NewFramingProtobufDecoder returns a new Decoder of Protobuf messages read from the
// given io.Reader to Events suitable for decoding a streaming response.
NewFramingProtobufDecoder returns a new Decoder of Protobuf messages read from the
given io.Reader to Events suitable for decoding a streaming response.
// NewFramingProtobufDecoder returns a new Decoder of Protobuf messages read from the // given io . Reader to Events suitable for decoding a streaming response .
func NewFramingProtobufDecoder(r io.Reader) Decoder {
	uf := func(b []byte, m interface{}) error {
		return pb.Unmarshal(b, m.(pb.Message))
	}
	dec := framing.NewDecoder(recordio.NewFrameReader(r), uf)
	return func(u Unmarshaler) error { return dec.Decode(u) }
}
func NewFramingProtobufDecoder ( r io . Reader ) Decoder { uf := func ( b [ ] byte , m interface { } ) error { return pb . Unmarshal ( b , m . ( pb . Message ) ) } dec := framing . NewDecoder ( recordio . NewFrameReader ( r ) , uf ) return func ( u Unmarshaler ) error { return dec . Decode ( u ) } }
NewFramingProtobufDecoder returns a new Decoder of Protobuf messages read from the
given io.Reader to Events suitable for decoding a streaming response.
NewFramingProtobufDecoder returns a new Decoder of Protobuf messages read from the given io . Reader to Events suitable for decoding a streaming response .