rename method

This commit is contained in:
longerian
2018-04-03 09:26:39 +08:00
parent adf9224dda
commit c9cd50ff66
2 changed files with 4 additions and 4 deletions
@@ -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
@@ -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 {