[test] With NSE expiration

Signed-off-by: Artem Glazychev <artem.glazychev@xored.com>

.github/workflows/ci.yaml

@@ -35,7 +35,7 @@ jobs:
       - name: Build
         run: go build -race  ./...
       - name: Test
-        run: go test -race -count 50 -run "TestNSMGR_.*" -timeout 1h ./...
+        run: go test -race -count 50 -run "TestNSMGR_CloseHeal" -timeout 1h ./...
   golangci-lint:
     name: golangci-lint
     runs-on: ubuntu-latest

pkg/networkservice/chains/nsmgr/heal_test.go

@@ -344,13 +344,13 @@ func TestNSMGR_CloseHeal(t *testing.T) {
 		name              string
 		withNSEExpiration bool
 	}{
-		{
-			name: "Without NSE expiration",
-		},
 		//{
-		//	name:              "With NSE expiration",
-		//	withNSEExpiration: true,
+		//	name: "Without NSE expiration",
 		//},
+		{
+			name:              "With NSE expiration",
+			withNSEExpiration: true,
+		},
 	}
 
 	for _, sample := range samples {

pkg/registry/common/memory/nse_server.go

@@ -91,7 +91,12 @@ func (s *memoryNSEServer) Find(query *registry.NetworkServiceEndpointQuery, serv
 
 	s.executor.AsyncExec(func() {
 		s.eventChannels[id] = eventCh
-		for _, entity := range s.allMatches(query) {
+		matches := s.allMatches(query)
+		if len(matches) == 0 {
+			eventCh <- nil
+			return
+		}
+		for _, entity := range matches {
 			eventCh <- entity
 		}
 	})
@@ -142,6 +147,9 @@ func (s *memoryNSEServer) receiveEvent(
 	case <-server.Context().Done():
 		return io.EOF
 	case event := <-eventCh:
+		if event == nil {
+			return nil
+		}
 		if matchutils.MatchNetworkServiceEndpoints(query.NetworkServiceEndpoint, event) {
 			if err := server.Send(event); err != nil {
 				if server.Context().Err() != nil {