Method NewEncoder

runtime/marshal_proto.go:48–60

NewEncoder returns an Encoder which writes proto stream into "writer".

(writer io.Writer)

// NewEncoder returns an Encoder which writes proto stream into "writer".
func (marshaller *ProtoMarshaller) NewEncoder(writer io.Writer) Encoder {
	return EncoderFunc(func(value interface{}) error {
		buffer, err := marshaller.Marshal(value)
		if err != nil {
			return err
		}
		if _, err := writer.Write(buffer); err != nil {
			return err
		}

		return nil
	})
}