View Javadoc
1   package us.codecraft.webmagic.pipeline;
2   
3   import us.codecraft.webmagic.Task;
4   
5   import java.util.ArrayList;
6   import java.util.List;
7   
8   /**
9    * @author code4crafter@gmail.com
10   */
11  public class CollectorPageModelPipeline<T> implements PageModelPipeline<T> {
12  
13      private List<T> collected = new ArrayList<T>();
14  
15      @Override
16      public synchronized void process(T t, Task task) {
17          collected.add(t);
18      }
19  
20      public List<T> getCollected() {
21          return collected;
22      }
23  }