From c9cd50ff66978e0936dc55f1d6df28fa0e269105 Mon Sep 17 00:00:00 2001
From: longerian <xlhongultimate@gmail.com>
Date: Tue, 3 Apr 2018 09:26:39 +0800
Subject: [PATCH] rename method

---
 .../com/tmall/wireless/tangram/example/RxTangramActivity.java | 4 ++--
 .../java/com/tmall/wireless/tangram/BaseTangramEngine.java    | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/examples/src/main/java/com/tmall/wireless/tangram/example/RxTangramActivity.java b/examples/src/main/java/com/tmall/wireless/tangram/example/RxTangramActivity.java
index aebafd1..764f5ab 100644
--- a/examples/src/main/java/com/tmall/wireless/tangram/example/RxTangramActivity.java
+++ b/examples/src/main/java/com/tmall/wireless/tangram/example/RxTangramActivity.java
@@ -365,7 +365,7 @@ public class RxTangramActivity extends Activity {
         //            Log.d("TangramActivity", "do subscribe in thread " + Thread.currentThread().getName());
         //        }
         //    })
-        //    .subscribe(engine.asOriginalDataConsume());
+        //    .subscribe(engine.asOriginalDataConsumer());
 
         // method 2, use transformer api
         //Observable.fromCallable(new Callable<byte[]>() {
@@ -396,7 +396,7 @@ public class RxTangramActivity extends Activity {
         //            Log.d("TangramActivity", "do subscribe in thread " + Thread.currentThread().getName());
         //        }
         //    })
-        //    .subscribe(engine.asParsedDataConsume());
+        //    .subscribe(engine.asParsedDataConsumer());
         // method 3, emit json array and flat map to jsonobject
         Disposable dsp8 = Observable.create(new ObservableOnSubscribe<JSONArray>() {
             @Override
diff --git a/tangram/src/main/java/com/tmall/wireless/tangram/BaseTangramEngine.java b/tangram/src/main/java/com/tmall/wireless/tangram/BaseTangramEngine.java
index 4c26280..6be65ee 100644
--- a/tangram/src/main/java/com/tmall/wireless/tangram/BaseTangramEngine.java
+++ b/tangram/src/main/java/com/tmall/wireless/tangram/BaseTangramEngine.java
@@ -375,7 +375,7 @@ public class BaseTangramEngine<O, T, C, L> implements ServiceManager {
      * @return A consumer will call {@link BaseTangramEngine#setData(Object)}
      * @since 3.0.0
      */
-    public Consumer<T> asOriginalDataConsume() {
+    public Consumer<T> asOriginalDataConsumer() {
         return new Consumer<T>() {
             @Override
             public void accept(T t) throws Exception {
@@ -389,7 +389,7 @@ public class BaseTangramEngine<O, T, C, L> implements ServiceManager {
      * @return A consumer will call {@link BaseTangramEngine#setData(List)}
      * @since 3.0.0
      */
-    public Consumer<List<C>> asParsedDataConsume() {
+    public Consumer<List<C>> asParsedDataConsumer() {
         return new Consumer<List<C>>() {
             @Override
             public void accept(List<C> cs) throws Exception {