diff --git a/agent/grpc-external/services/peerstream/stream_resources.go b/agent/grpc-external/services/peerstream/stream_resources.go index 9728d0db7d..cfffe32aef 100644 --- a/agent/grpc-external/services/peerstream/stream_resources.go +++ b/agent/grpc-external/services/peerstream/stream_resources.go @@ -170,10 +170,9 @@ func (s *Server) StreamResources(stream pbpeerstream.PeerStreamService_StreamRes } logTraceSend(logger, term) - err := stream.Send(term) - if err != nil { - return grpcstatus.Error(codes.FailedPrecondition, "peering is marked as deleted: "+req.PeerID) - } + // we don't care if send fails; stream will be killed by termination message or grpc error + _ = stream.Send(term) + return grpcstatus.Error(codes.FailedPrecondition, "peering is marked as deleted: "+req.PeerID) } secrets, err := s.GetStore().PeeringSecretsRead(nil, req.PeerID)