sip

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 {