安卓基础知识程序员Android开发

RxJava 学习进行时&实际运用-Buffer&

2016-07-01  本文已影响580人  郑鸿翊
RX

1. buffer

详见

Buffer官方介绍
操作符将一个Observable变换为另一个,原来的Observable正常发射数据,变换产生的Observable发射这些数据的缓存集合。Buffer
操作符在很多语言特定的实现中有很多种变体,它们在如何缓存这个问题上存在区别。

测试代码:构建一个String数组,发布者(Observable)的行为是缓存 count 个消息并打包发送,订阅者的行为是接受每个发送来的List并打印。

//数据源
String[] strs = {"a","b","c","d","e","f","g","h","i"};
//发布者
Observable<String> origin = Observable.from(strs);
//订阅者
Subscriber<String> sub = new Subscriber<String>() {
      @Override
      public void onCompleted() {
           Log.d("log", "Completed");
      }

       @Override
       public void onError(Throwable e) {
            Log.d("log", "Error");
       }

       @Override
       public void onNext(String s) {
            Log.d("log", "Next--------");
            for (int i = 0 ; i < s.size();i++){
                 Log.d("log", s.get(i));
            }
        }
};
origin.buffer(2,1).subscribe(sub);
result

可见是缓存两个信息,并且打包发出,而且下一次的缓存位置是在当前缓存队列的第1位(指的是下标)开始。

origin.buffer(2,2).subscribe(sub);
result
同样是缓存了两个信息,而下一次的缓存开始位置是在队列的第2位(指的是下标,说明一下,这里的队列是当前还未发送的信息的队列,之前已经发送的是不算的
origin.buffer(2,3).subscribe(sub);
result

c没了,f也没了,i同样消失了!

2. interval

详见

简介的官方介绍,简单却实用
创建一个按固定时间间隔发射整数序列的Observable

之前写倒计时的控件都是用Handler或者Timer去做的,现在有这个就可以很方便的写出倒计时控件,下面是我写的一个倒计时按钮。
可以看到里面倒计时时数字有抖动,是模拟器的问题,在真机上是不会的(亲测)。

e1.gif e2.gif
/**
 * Created by ZhengHy on 2016/6/30 0030.
 * 倒计时Button
 */

public class CountDownButton extends Button{
    /**
     * 默认倒计时时间
     */
    private final int DEFAULT_COUNT = 60;

    /**
     * 倒计时时间
     */
    private int iTotalCount = DEFAULT_COUNT;

    private int iCountingNum = DEFAULT_COUNT;

    /**
     * 默认开始显示的字符串
     */
    private final String DEFAULT_START_STR = "开始";

    /**
     * 开始显示的字符串
     */
    private String sStartStr = DEFAULT_START_STR;

    /**
     * 等待颜色
     */
    private int normalColor = 0xffff4000;

    /**
     * 倒计时颜色
     */
    private int countingColor = 0xffffffff;

    /**
     * 倒计时订阅者
     */
    private Subscriber<Long> countDownTimer;


    public CountDownButton(Context context) {
        super(context);
        init();
    }

    public CountDownButton(Context context, AttributeSet attrs) {
        super(context, attrs);
        init();
    }

    public CountDownButton(Context context, AttributeSet attrs, int defStyleAttr) {
        super(context, attrs, defStyleAttr);
        init();
    }

    private void init() {
        onPre();
    }

    public int getiTotalCount() {
        return iTotalCount;
    }

    public void setiTotalCount(int iTotalCount) {
        this.iTotalCount = iTotalCount;
        this.iCountingNum = iTotalCount;
    }

    /**
     * 开始倒计时
     */
    public void countDown() {
        initTimer();
        onCounting();
        Observable.interval(0, 1, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(countDownTimer);

    }

    private void initTimer() {
        countDownTimer = new Subscriber<Long>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(Long aLong) {
                iCountingNum--;

                setText(iCountingNum + "");
                if (iCountingNum == 0l) {
                    countDownTimer.unsubscribe();
                    setClickable(true);
                    onPre();

                }
            }
        };
    }

    /**
     * 停止倒计时 恢复成最初样子
     */
    public void shutDown() {
        if (countDownTimer != null) {
            countDownTimer.unsubscribe();
            onPre();
        }
    }

    private void onPre() {
        setClickable(true);
        iCountingNum = iTotalCount;
        setText(sStartStr);
        setTextColor(normalColor);
    }

    private void onCounting() {
        setClickable(false);
        setTextColor(countingColor);
    }
}

页面布局
<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout
    xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    >

    <Button
        android:text="shutdown"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:layout_below="@+id/cdb"
        android:layout_alignEnd="@+id/cdb"
        android:layout_marginTop="20dp"
        android:id="@+id/btn" />

    <network.scau.com.countdownbuttondemo.CountDownButton
        android:background="#ff000000"
        android:id="@+id/cdb"
        android:layout_width="100dp"
        android:layout_height="50dp"
        android:gravity="center"
        android:layout_centerVertical="true"
        android:layout_centerHorizontal="true" />
</RelativeLayout>

MainActivity,使用ButterKnife注入控件
public class MainActivity extends AppCompatActivity {

    @Bind(R.id.btn)
    Button btn;

    @Bind(R.id.cdb)
    CountDownButton cdb;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        ButterKnife.bind(this);
    }

    @OnClick(R.id.cdb)
    public void countting() {
        Toast.makeText(this,"countting",Toast.LENGTH_LONG).show();
        cdb.countDown();

    }

    @OnClick(R.id.btn)
    public void shutdown(){
        Toast.makeText(this,"shutdown",Toast.LENGTH_LONG).show();
        cdb.shutDown();
    }
}


有趣的Rx。

上一篇 下一篇

猜你喜欢

热点阅读