package engine_test import ( "context" "sync/atomic" "testing" "time" foxhound "github.com/sadewadee/foxhound" "github.com/sadewadee/foxhound/engine" ) // --------------------------------------------------------------------------- // Helpers shared across stream tests // --------------------------------------------------------------------------- // streamItem produces a simple Item with a counter field set to n. func streamItem(n int) *foxhound.Item { it := foxhound.NewItem() it.Set("n", n) return it } // htmlBody is a minimal valid HTML body that will not trigger captcha/detect's // empty_trap heuristic (which fires when body < 500 bytes and lacks