RxJava - jak wywołać abonenta 4 zdarzeń kliknij Androida

Question

W android Mam widoku tekstu zdefiniowany następująco:

<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" /> 

Moim celem jest to, że po kliknięciu 4 razy, chcę zacząć nowy czynność. Muszę to zrobić z RXJava; to jest wymaganie. Lub rxAndroid, rxBinding itp

Moja aktywność wygląda następująco:

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){ 

     } 
    } 
} 

UPDATE: ale jest to po prostu standardowy sposób to zrobić. Z reaktywnym interfejsem API rxJava musi być jakiś sposób.

Więc zamiast używać onClicklistener z rxBinding czytałem możemy to zrobić:

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"); 
    }); 

można jakoś użyć polecenia w rxBinding aby wykonać dopiero po 4 kliknięcia? Nie chcę przechowywać zmiennej statycznej, lub użyć anonimowej klasy i przechowywać zmienną składową, aby ją policzyć. Powinna istnieć możliwa do zaobserwowania metoda.

Answer 1

Można utworzyć obserwowalne, aby emitować za każdym razem, gdy kliknięto przycisk, a następnie policzyć całkowite czasy emisji, a następnie użyć filtra, aby subskrybent zobaczył je tylko po czterokrotnym wyemitowaniu.

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

Answer 2

można osiągnąć coś takiego:

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() - gromadzić kliknięcia na oknie 1s
• filter() - filtrowania wszystkich emitowanych buforowane elementy, gdzie jest liczba elementów w buforze nie równe 4 (wyłącz podwójne, potrójne, pięciokrotne kliknięcia)

Najtrudniejszą częścią jest określenie czasu "okna" bufora. Jedna sekunda czasami nie wystarcza, ale w innych przypadkach użytkownik musi odczekać kilka milisekund.

Answer 3

@skywall odpowiedź jest najbardziej kompletny, jednak jeśli nie dbają o przedziałach czasowych najprostsza odpowiedź będzie używać skip

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

Answer 4

Jeśli chcesz rozpocząć działalność po pewnej liczbie kliknięć w okno czasowe, a następnie spróbuj tego:

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()); 

Answer 5

Użyj bufora i operatora odbicia.

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