(data []byte, v interface{})
| 58 | return proto.Marshal(v.(proto.Message)) |
| 59 | } |
| 60 | func (passthroughCodec) Unmarshal(data []byte, v interface{}) error { |
| 61 | if m, ok := v.(*rawMessage); ok { |
| 62 | m.data = append([]byte(nil), data...) |
| 63 | return nil |
| 64 | } |
| 65 | return proto.Unmarshal(data, v.(proto.Message)) |
| 66 | } |
| 67 | |
| 68 | // createLengthPrefixedMessage creates a GrpcLengthPrefixedMessage from a raw message payload. |
| 69 | func createLengthPrefixedMessage(data []byte) models.GrpcLengthPrefixedMessage { |
no outgoing calls