Android将基本计时器转换为RxJava

我创建了一个简单的计时器，计数从0到30，间隔为1秒。我想达到相同，但它必须从30到0计数，它必须用RxJava完成。有人可以提供我样品转换吗？Android将基本计时器转换为RxJava

这里是我的代码：

TextView timerTextView; 
long startTime = 0; 

//runs without a timer by reposting this handler at the end of the runnable 
Handler timerHandler = new Handler(); 
Runnable timerRunnable = new Runnable() { 

    @Override 
    public void run() { 
     long millis = System.currentTimeMillis() - startTime; 
     int seconds = (int) (millis/1000); 
     int minutes = seconds/60; 
     seconds = seconds % 60; 

     timerTextView.setText(String.format("%d:%02d", minutes, seconds)); 

     timerHandler.postDelayed(this, 500); 
    } 
}; 

@Override 
public void onCreate(Bundle savedInstanceState) { 
    super.onCreate(savedInstanceState); 
    setContentView(R.layout.activity_main); 

    timerTextView = (TextView) findViewById(R.id.textView); 

    Button b = (Button) findViewById(R.id.button); 
    b.setText("start"); 
    b.setOnClickListener(new View.OnClickListener() { 

     @Override 
     public void onClick(View v) { 
      Button b = (Button) v; 
      if (b.getText().equals("stop")) { 
       timerTextView.setText("0:00"); 
       timerHandler.removeCallbacks(timerRunnable); 
       b.setText("start"); 
      } else { 
       startTime = System.currentTimeMillis(); 
       timerHandler.postDelayed(timerRunnable, 0); 
       b.setText("stop"); 
      } 
     } 
    }); 

    timerTextView.addTextChangedListener(new TextWatcher() { 
     @Override 
     public void beforeTextChanged(CharSequence s, int start, int count, int after) { 
     } 

     @Override 
     public void onTextChanged(CharSequence s, int start, int before, int count) { 
      if(timerTextView.getText().toString().equals("0:30")){ 
       Toast.makeText(MainActivity.this, "End of time!", Toast.LENGTH_SHORT).show(); 
      } 
     } 

     @Override 
     public void afterTextChanged(Editable s) { 
     } 
    }); 
}

来源

2017-02-19 wegtis

嗯，我不知道如何使用倒车档，但简单的方法是使用下面的：

final int startCount = 30; 
final Observable<Integer> observable = Observable 
      .range(0, startCount) 
      .concatMap(
        i -> Observable.just(i) 
          .delay(1, TimeUnit.SECONDS) 
          .map(it -> startCount - it) 
      ); 

final Subscription subscription = observable.subscribe(System.out::println);

和取消时的onStop（）调用

@Override 
public void onStop(){ 
    subscription.unsubscribe(); 
}

或不拉姆达：

final int startCount = 30; 
final Observable<Integer> observable = Observable 
      .range(0, startCount) 
      .concatMap(new Func1<Integer, Observable<? extends Integer>>() { 
          @Override 
          public Observable<? extends Integer> call(Integer integer) { 
           return Observable.just(integer) 
             .delay(1, TimeUnit.SECONDS) 
             .map(new Func1<Integer, Integer>() { 
              @Override 
              public Integer call(Integer integer) { 
               return startCount - integer; 
              } 
             }); 
          } 
         } 
      ); 

final Subscription subscription = observable 
      .subscribe(new Action1<Integer>() { 
       @Override 
       public void call(Integer integer) { 
        System.out.println(integer); 
       } 
      });

课程和申请schedulers可观察

.subscribeOn(Schedulers.newThread()) 
.observeOn(AndroidSchedulers.mainThread())

来源

2017-02-19 17:33:22 ROBOHORSE

它没有那么复杂：

Observable.interval(1, TimeUnit.SECONDS, AndroidSchedulers.mainThread()) 
.take(31) // 0, 1, 2, ..., 30 
.map(new Func1<Long, Integer>() { 
    @Override public Integer call(Long value) { 
     return 30 - value.intValue(); 
    } 
}) 
.subscribe(new Action1<Integer>() { 
    @Override public void call(Integer value) { 
      System.out.println(value); 
    } 
});

来源

2017-02-19 19:51:31 akarnokd

Android将基本计时器转换为RxJava

回答

相关问题