# RxJavaShowcase

**Repository Path**: mirrors_donglua/RxJavaShowcase

## Basic Information

- **Project Name**: RxJavaShowcase
- **Description**: 几个RxJava的小例子
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-08-08
- **Last Updated**: 2026-05-16

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# RxJavaShowcase
RxJava示例

* 统计连续点击
```java
mClickCountSubject.asObservable() 
    .buffer(mClickCountSubject.throttleWithTimeout(300, TimeUnit.MILLISECONDS)) 
    .map(List::size) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(count -> { 
      Snackbar.make(mButton, "连续点击了" + count + "次", LENGTH_SHORT).show();
    }); 
```

* 倒计时

```java
Observable.interval(1, TimeUnit.SECONDS)
        .take(11) 
        .map(i -> { 
          return 10 - i; // i为0~10 11次 
        }) 
        .observeOn(AndroidSchedulers.mainThread()) 
        .subscribe(i -> { 
          btCountDown.setText(i == 0 ? "倒计时" : "" + i);
          if (i == 0) btCountDown.setEnabled(true);
        }); 
```