Handle EOF error when reading stream.

Author: Roman Golov

CHANGELOG.md

@@ -1,3 +1,5 @@
+* Fixed unhandled EOF in topic service
+
 ## v3.56.1
 * Fixed fixenv usage (related to tests only)
 

internal/grpcwrapper/rawtopic/rawtopicreader/rawtopicreader.go

@@ -3,6 +3,7 @@ package rawtopicreader
 import (
 	"errors"
 	"fmt"
+	"io"
 	"reflect"
 
 	"github.com/ydb-platform/ydb-go-genproto/protos/Ydb_Topic"
@@ -30,6 +31,9 @@ func (s StreamReader) CloseSend() error {
 
 func (s StreamReader) Recv() (ServerMessage, error) {
 	grpcMess, err := s.Stream.Recv()
+	if xerrors.Is(err, io.EOF) {
+		return nil, err
+	}
 	if err != nil {
 		if !xerrors.IsErrorFromServer(err) {
 			err = xerrors.Transport(err)