From d58fb742ecc9f8ada721121bf749e23e43ee18e6 Mon Sep 17 00:00:00 2001 From: Robert Burke Date: Fri, 5 Jun 2020 12:31:52 -0700 Subject: [PATCH] remove LP indicator (#11937) --- sdks/go/pkg/beam/core/graph/coder/stringutf8.go | 8 ++++---- sdks/go/pkg/beam/core/graph/coder/stringutf8_test.go | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/sdks/go/pkg/beam/core/graph/coder/stringutf8.go b/sdks/go/pkg/beam/core/graph/coder/stringutf8.go index 22944353a5e32..d70df6acef685 100644 --- a/sdks/go/pkg/beam/core/graph/coder/stringutf8.go +++ b/sdks/go/pkg/beam/core/graph/coder/stringutf8.go @@ -24,8 +24,8 @@ import ( const bufCap = 64 -// EncodeStringUTF8LP encodes a UTF string with a length prefix. -func EncodeStringUTF8LP(s string, w io.Writer) error { +// EncodeStringUTF8 encodes a UTF8 string with a length prefix. +func EncodeStringUTF8(s string, w io.Writer) error { if err := EncodeVarInt(int64(len(s)), w); err != nil { return err } @@ -73,8 +73,8 @@ func decodeStringUTF8(l int64, r io.Reader) (string, error) { return builder.String(), nil } -// DecodeStringUTF8LP decodes a length prefixed utf8 string. -func DecodeStringUTF8LP(r io.Reader) (string, error) { +// DecodeStringUTF8 decodes a length prefixed UTF8 string. +func DecodeStringUTF8(r io.Reader) (string, error) { l, err := DecodeVarInt(r) if err != nil { return "", err diff --git a/sdks/go/pkg/beam/core/graph/coder/stringutf8_test.go b/sdks/go/pkg/beam/core/graph/coder/stringutf8_test.go index 75857e8f7018c..2170a2851340f 100644 --- a/sdks/go/pkg/beam/core/graph/coder/stringutf8_test.go +++ b/sdks/go/pkg/beam/core/graph/coder/stringutf8_test.go @@ -106,11 +106,11 @@ func TestEncodeDecodeStringUTF8LP(t *testing.T) { want := s t.Run(want, func(t *testing.T) { var build strings.Builder - if err := EncodeStringUTF8LP(want, &build); err != nil { + if err := EncodeStringUTF8(want, &build); err != nil { t.Fatal(err) } buf := bytes.NewBufferString(build.String()) - got, err := DecodeStringUTF8LP(buf) + got, err := DecodeStringUTF8(buf) if err != nil && err != io.EOF { t.Fatal(err) }