Back pressure example: ThrottleLast. Minor refactor.

Author: android10

app/src/main/java/com/fernandocejas/android10/rx/sample/activity/backpressure/ActivityBackpressureSamples.java

@@ -17,6 +17,8 @@
 
 import android.content.Context;
 import android.content.Intent;
+import android.content.res.ColorStateList;
+import android.graphics.Color;
 import android.os.Bundle;
 import android.view.Window;
 import android.widget.TextView;
@@ -30,6 +32,7 @@
 import com.fernandocejas.android10.rx.sample.data.StringGenerator;
 import com.fernandocejas.android10.rx.sample.executor.JobExecutor;
 import com.fernandocejas.arrow.strings.Strings;
+import java.util.concurrent.TimeUnit;
 import rx.Subscription;
 import rx.android.schedulers.AndroidSchedulers;
 import rx.schedulers.Schedulers;
@@ -115,7 +118,15 @@ private void toggleProgressBar(boolean visible) {
  .toList()
  .observeOn(AndroidSchedulers.mainThread())
  .subscribeOn(Schedulers.computation())
- .subscribe(new BackpressureSubscriber<>(this, getString(R.string.btn_text_backpressure_tolist), 1000));
+ .subscribe(new BackpressureSubscriber<>(this, getString(R.string.btn_text_backpressure_toList), 1000));
+ }
+
+ @OnClick(R.id.btn_backpressureThrottleLast) void onBackpressureThrottleLast() {
+ dataManager.milliseconds(10000)
+ .throttleLast(10, TimeUnit.MILLISECONDS)
+ .observeOn(AndroidSchedulers.mainThread())
+ .subscribeOn(Schedulers.computation())
+ .subscribe(new BackpressureSubscriber<>(this, getString(R.string.btn_text_backpressure_throttleLast), 10000));
  }
 
  @Override
@@ -133,21 +144,25 @@ public void onOperationStart(String name, long itemsRequested) {
  @Override
  public void onOperationResult(long itemsEmitted, OperationResult operation) {
  tv_itemsEmitted.setText(String.valueOf(itemsEmitted));
- String resultMessage = Strings.EMPTY;
  switch (operation.result()) {
  case SUCCESS:
- resultMessage = getString(R.string.string_success);
+ tv_result.setText(getString(R.string.string_success));
+ tv_result.setTextColor(ColorStateList.valueOf(Color.BLUE));
  break;
  case FAILURE:
+ String failureMessage;
  if (operation.throwable().isPresent()) {
- resultMessage = String.format(getString(R.string.string_failure),
+ failureMessage = String.format(getString(R.string.string_failure),
  operation.throwable().get().toString());
  } else {
- resultMessage = getString(R.string.string_failure);
+ failureMessage = getString(R.string.string_failure);
  }
+ tv_result.setText(failureMessage);
+ tv_result.setTextColor(ColorStateList.valueOf(Color.RED));
  break;
+ default:
+ tv_result.setText(Strings.EMPTY);
  }
- tv_result.setText(resultMessage);
  toggleProgressBar(false);
  }
 }

app/src/main/res/layout/activity_samples_backpressure.xml

@@ -39,7 +39,14 @@
  android:id="@+id/btn_backpressureToList"
  android:layout_width="match_parent"
  android:layout_height="wrap_content"
- android:text="@string/btn_text_backpressure_tolist"
+ android:text="@string/btn_text_backpressure_toList"
+ />
+
+ <Button
+ android:id="@+id/btn_backpressureThrottleLast"
+ android:layout_width="match_parent"
+ android:layout_height="wrap_content"
+ android:text="@string/btn_text_backpressure_throttleLast"
  />
 
  <LinearLayout

app/src/main/res/values/strings.xml

@@ -26,10 +26,11 @@
  <string name="tv_label_backpressure_items_processed">Items processed:</string>
  <string name="tv_label_backpressure_items_emitted">Items emitted:</string>
  <string name="tv_label_backpressure_result">Result:</string>
- <string name="btn_text_backpressure_exception">Backpressure exception</string>
- <string name="btn_text_backpressure_drop">Backpressure drop items</string>
- <string name="btn_text_backpressure_buffer">Backpressure buffer items</string>
- <string name="btn_text_backpressure_tolist">Backpressure toList</string>
+ <string name="btn_text_backpressure_exception">Backpressure Exception</string>
+ <string name="btn_text_backpressure_drop">Backpressure Drop Items</string>
+ <string name="btn_text_backpressure_buffer">Backpressure Buffer Items</string>
+ <string name="btn_text_backpressure_toList">Backpressure To List</string>
+ <string name="btn_text_backpressure_throttleLast">Backpressure Throttle Last</string>
 
  <string name="string_content_description">Non accessible view</string>