RxJava - 如何在 Android 中的 4 个点击事件上调用订阅者

Question

在 android 中，我有一个这样定义的文本视图：

<TextView
     android:id="@+id/text1"       
     android:layout_width="wrap_content"
     android:layout_height="wrap_content"
     android:text="@string/hello_world"
     android:textColorHighlight="#000000"
     android:textIsSelectable="true" />

我的目标是点击4次后，我想开始一个新的活动。我需要用 RXJava 来做这件事；这是一个要求。或者rxAndroid、rxBinding等。

我的活动如下所示：

public class MainActivity extends Activity implements onClickListener {
    TextView tv;
    /** Called when the activity is first created. */
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        tv=(TextView)findViewById(R.id.text1);
        tv.setOnClickListener(this);
    }

    @Override
    public void onClick(View v) {
        if(v.getId() == R.id.text1){

        }
    }
}

更新： 但这只是标准的做法。必须有办法使用响应式 rxJava API。

所以我读到我们可以这样做：

RxView.clicks(tv).flatMap(tv -> { 
        // another observable which can throw onError. 
        return Observable.error(null); 
    }).subscribe(object -> { 
        Log.d("CLICK", "textview clicked", start activity);
    }, error -> { 
        Log.d("CLICK", "ERROR");
    });

我能否以某种方式使用rxBinding 中的命令使其仅在单击 4 次后执行？我不希望存储静态变量，或使用匿名类并在其中存储成员变量以供计数。应该有一个可观察的方法。

Answer 1

您可以通过以下方式实现：

Observable.create((Observable.OnSubscribe<Void>) subscriber -> {
    if (!subscriber.isUnsubscribed()) {
        button.setOnClickListener(v -> subscriber.onNext(null));
    }
}).buffer(1000, TimeUnit.MILLISECONDS)
        .filter(clicks -> clicks.size() == 4)
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(clicks -> {
            Log.d("CLICK", "CLICK");
        });

• buffer() - 为 1 秒的窗口收集点击次数
• filter() - 过滤所有发出的缓冲项，其中缓冲区中的项数不等于 4（禁用双、三、五次点击）

最难的部分是指定缓冲时间“窗口”。一秒钟有时是不够的，但在其他情况下，用户必须等待几毫秒。

Answer 2

您可以创建一个 observable 以在每次单击按钮时发出，然后计算它发出的总次数，并使用过滤器，以便您的订阅者只有在发出四次后才能看到它。

Observable<View> buttonObservable = ViewObservable.clicks(initiateButton, false);
buttonObservable.count()
        .filter(count -> (count >= 4))
        .subscribe(object -> {
            //Your code here
        });

Answer 3

对于检测具有合理超时的多次点击（例如，在 1000 毫秒内点击 4 次），以下方法效果很好：

    final int numClicks = 4;
    final int timeout = 1000;
    disposables.add(RxView.clicks(tv)
            .buffer(timeout, TimeUnit.MILLISECONDS, numClicks)
            .filter(list -> list.size() == numClicks)
            .subscribe(this::doThing));

在此示例中，buffer 将发出 4 个事件，或者每 1000 毫秒发出少于 4 个事件，由于filter，这将被忽略

Answer 4

@skywall 答案是最完整的，但是如果您不关心时间间隔，最简单的答案是使用skip

Observable<Void> fourClicksView = RxView.clicks(tv).skip(3); 
fourClicksView.subscribe(...);

Answer 5

使用缓冲和去抖动运算符。

val clickStream = RxView.clicks(view)
    clickStream.buffer(clickStream.debounce(250, TimeUnit.MILLISECONDS))
            .map { it.size }
            .filter { it == 4 }
            .subscribe({
            })

Answer 6

如果你想在一个时间窗口内点击一定次数后开始一个活动，那么试试这个：

RxView.clicks(tv)
    .map(e -> SystemClock.elapsedRealtime())
    .buffer(NUM_CLICKS, 1) //Grab every sub-sequence of however many clicks
    .filter(times -> times.size() == NUM_CLICKS) //Last values will be truncated
    .filter(times -> times.get(NUM_CLICKS - 1) - times.get(0) < ALLOWED_TIME) //check times
    .subscribe(ignore -> startActivity());