diff --git a/pkg/log/client.go b/pkg/log/client.go index 1c12c583065fe2f875792b56bfebe32eba6d8b28..559b7cab5ebd5454c7c5296513cffe53a8b4a962 100644 --- a/pkg/log/client.go +++ b/pkg/log/client.go @@ -2,6 +2,8 @@ package log import ( "context" + "fmt" + "io" "git.perx.ru/perxis/perxis-go/pkg/errors" errorsgrpc "git.perx.ru/perxis/perxis-go/pkg/errors/grpc" @@ -38,6 +40,10 @@ func (c *Client) Log(ctx context.Context, entries <-chan *Entry) error { response, err := stream.CloseAndRecv() if err != nil { + if errors.Is(err, io.EOF) { + fmt.Println("EOF, OK") + return nil + } return err } if response.GetError() != nil {