diff --git a/rpcserver.go b/rpcserver.go index b0aae3a09..463677e7b 100644 --- a/rpcserver.go +++ b/rpcserver.go @@ -7193,7 +7193,12 @@ func (r *rpcServer) SendPayment(req *tchrpc.SendPaymentRequest, update, err := updateStream.Recv() if err != nil { - return err + // Stream is closed; no more updates. + if err == io.EOF { + return nil + } + return fmt.Errorf("failed to receive payment "+ + "update: %w", err) } err = stream.Send(&tchrpc.SendPaymentResponse{