fixed #916 by addressing the failure to terminate

Author: caffix

enum/input.go

@@ -11,12 +11,12 @@ import (
 	"sync"
 	"time"
 
-	amassnet "github.com/owasp-amass/amass/v3/net"
-	"github.com/owasp-amass/amass/v3/net/dns"
-	"github.com/owasp-amass/amass/v3/requests"
 	"github.com/caffix/pipeline"
 	"github.com/caffix/queue"
 	"github.com/caffix/service"
+	amassnet "github.com/owasp-amass/amass/v3/net"
+	"github.com/owasp-amass/amass/v3/net/dns"
+	"github.com/owasp-amass/amass/v3/requests"
 	bf "github.com/tylertreat/BoomFilters"
 )
 
@@ -189,8 +189,7 @@ func (r *enumSource) Next(ctx context.Context) bool {
 			r.markDone()
 			return false
 		case <-t.C:
-			if r.pipeline.DataItemCount() <= 0 &&
-				!r.enum.requestsPending() && r.queue.Len() == 0 {
+			if !r.enum.requestsPending() && r.queue.Len() == 0 {
 				r.markDone()
 				return false
 			}