(t *testing.T)
| 115 | } |
| 116 | |
| 117 | func TestCrawler_Process_downloadError(t *testing.T) { |
| 118 | scheduler.Init(4, 0) |
| 119 | cr := New(0, &errorDownloader{}, "csv", 10).(*crawler) |
| 120 | sp := &spider.Spider{ |
| 121 | Name: "TestSpider", |
| 122 | RuleTree: &spider.RuleTree{Trunk: map[string]*spider.Rule{}}, |
| 123 | Limit: -5, |
| 124 | } |
| 125 | cr.Init(sp) |
| 126 | req := &request.Request{URL: "http://example.com", Rule: "r"} |
| 127 | req.Prepare() |
| 128 | cr.Process(req) |
| 129 | } |
| 130 | |
| 131 | func TestCrawler_Run(t *testing.T) { |
| 132 | scheduler.Init(4, 0) |