update

webmagic-core/src/main/java/us/codecraft/webmagic/annotation/ObjectPipeline.java

+package us.codecraft.webmagic.annotation;
+
+import us.codecraft.webmagic.ResultItems;
+import us.codecraft.webmagic.Task;
+import us.codecraft.webmagic.pipeline.Pipeline;
+
+/**
+ * @author yihua.huang@dianping.com <br>
+ * @date: 13-8-2 <br>
+ * Time: 上午10:47 <br>
+ */
+public class ObjectPipeline implements Pipeline {
+    @Override
+    public void process(ResultItems resultItems, Task task) {
+
+    }
+
+    public <T> T read() {
+        return null;
+    }
+}

webmagic-core/src/test/java/us/codecraft/webmagic/annotation/OschinaBlog.java

@@ -14,11 +14,4 @@ public class OschinaBlog {
     @ExtractBy(value = "div.BlogContent",type = ExtractBy.Type.Css)
     private String content;
 
-    @Override
-    public String toString() {
-        return "OschinaBlog{" +
-                "title='" + title + '\'' +
-                ", content='" + content + '\'' +
-                '}';
-    }
 }

webmagic-core/src/test/java/us/codecraft/webmagic/annotation/TestFetcher.java

@@ -15,7 +15,13 @@ public class TestFetcher {
     @Ignore("takes long")
     @Test
     public void test() {
-        Spider.create(ObjectPageProcessor.create(Site.me().addStartUrl("http://my.oschina.net/flashsword/blog/145796"), OschinaBlog.class)).run();
+        ObjectPipeline objectPipeline = new ObjectPipeline();
+        Spider.create(ObjectPageProcessor.create(Site.me().addStartUrl("http://my.oschina.net/flashsword/blog/145796"), OschinaBlog.class))
+                .pipeline(objectPipeline).runAsync();
+        OschinaBlog oschinaBlog = null;
+        while ((oschinaBlog = objectPipeline.read()) != null) {
+            System.out.println(oschinaBlog);
+        }
 
     }