Làm thế nào để sử dụng Flowable trong RxJava 2?

Question

Có giới thiệu về Lưu lượng mới trong RxJava2. Làm thế nào để sử dụng điều này trong Android. Không có Flowable trong RxJava1.

Answer 1

public class FlowableExampleActivity extends AppCompatActivity { 

    private static final String TAG = FlowableExampleActivity.class.getSimpleName(); 
    Button btn; 
    TextView textView; 

    @Override 
    protected void onCreate(Bundle savedInstanceState) { 
     super.onCreate(savedInstanceState); 
     setContentView(R.layout.activity_example); 
     btn = (Button) findViewById(R.id.btn); 
     textView = (TextView) findViewById(R.id.textView); 

     btn.setOnClickListener(new View.OnClickListener() { 
      @Override 
      public void onClick(View view) { 
       doSomeWork(); 
      } 
     }); 
    } 

    /* 
    * simple example using Flowable 
    */ 
    private void doSomeWork() { 

     Flowable<Integer> observable = Flowable.just(1, 2, 3, 4); 

     observable.reduce(50, new BiFunction<Integer, Integer, Integer>() { 
      @Override 
      public Integer apply(Integer t1, Integer t2) { 
       return t1 + t2; 
      } 
     }).subscribe(getObserver()); 

    } 

    private SingleObserver<Integer> getObserver() { 

    return new SingleObserver<Integer>() { 
     @Override 
     public void onSubscribe(Disposable d) { 
      Log.d(TAG, " onSubscribe : " + d.isDisposed()); 
     } 

     @Override 
     public void onSuccess(Integer value) { 
      Log.d(TAG, " onSuccess : value : " + value); 
     } 

     @Override 
     public void onError(Throwable e) { 
      Log.d(TAG, " onError : " + e.getMessage()); 
     } 
    }; 
} 
} 

Tôi có một dự án mẫu để minh họa việc sử dụng RxJava2. Ở đây bạn có thể tìm thấy sample project - RxJava2-Android-Samples

Answer 2

Đây là những gì nó nói trong các tài liệu

Thực tế, các fromEmitter 1.x (trước đây là fromAsync) đã được đổi tên để Flowable.create. Các loại phản ứng cơ sở khác có phương pháp tương tự tạo ra phương pháp (trừ chiến lược nén).

Vì vậy, bạn có thể sử dụng trong cùng một cách như fromEmitter và fromAsync

Rx.2 Documentation