diff options
Diffstat (limited to 'lib/go/thrift/duplicate_protocol.go')
| -rw-r--r-- | lib/go/thrift/duplicate_protocol.go | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/lib/go/thrift/duplicate_protocol.go b/lib/go/thrift/duplicate_protocol.go index c23d548c3..6413909d4 100644 --- a/lib/go/thrift/duplicate_protocol.go +++ b/lib/go/thrift/duplicate_protocol.go @@ -166,6 +166,12 @@ func (tdtp *TDuplicateToProtocol) WriteBinary(ctx context.Context, value []byte) return err } +func (tdtp *TDuplicateToProtocol) WriteUUID(ctx context.Context, value Tuuid) error { + err := tdtp.Delegate.WriteUUID(ctx, value) + tdtp.DuplicateTo.WriteUUID(ctx, value) + return err +} + func (tdtp *TDuplicateToProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqid int32, err error) { name, typeId, seqid, err = tdtp.Delegate.ReadMessageBegin(ctx) tdtp.DuplicateTo.WriteMessageBegin(ctx, name, typeId, seqid) @@ -286,6 +292,12 @@ func (tdtp *TDuplicateToProtocol) ReadBinary(ctx context.Context) (value []byte, return } +func (tdtp *TDuplicateToProtocol) ReadUUID(ctx context.Context) (value Tuuid, err error) { + value, err = tdtp.Delegate.ReadUUID(ctx) + tdtp.DuplicateTo.WriteUUID(ctx, value) + return +} + func (tdtp *TDuplicateToProtocol) Skip(ctx context.Context, fieldType TType) (err error) { err = tdtp.Delegate.Skip(ctx, fieldType) tdtp.DuplicateTo.Skip(ctx, fieldType) |