fix: provide unmarshal options for streams (#343)

We want to discard unknown so if the server sends new data we don't
blow up on it if our proto is not up-to-date.

v2/proto_json_stream.go

@@ -111,7 +111,8 @@ func (s *ProtoJSONStream) Recv() (proto.Message, error) {
 	// Initialize a new instance of the protobuf message to unmarshal the
 	// raw data into.
 	m := s.typ.New().Interface()
-	err := protojson.Unmarshal(raw, m)
+	unm := protojson.UnmarshalOptions{AllowPartial: true, DiscardUnknown: true}
+	err := unm.Unmarshal(raw, m)
 
 	return m, err
 }

v2/proto_json_stream_test.go

@@ -162,8 +162,9 @@ func prepareStream(messages []proto.Message) (io.ReadCloser, error) {
 	}
 
 	data := []byte("[")
+	mo := protojson.MarshalOptions{AllowPartial: true, UseEnumNumbers: true}
 	for _, m := range messages {
-		d, err := protojson.Marshal(m)
+		d, err := mo.Marshal(m)
 		if err != nil {
 			return nil, err
 		}