android手写最简单rxjava

  • N5_980124
    了解作者
  • 456.9KB
    文件大小
  • zip
    文件格式
  • 0
    收藏次数
  • VIP专享
    资源类型
  • 0
    下载次数
  • 2022-04-09 11:23
    上传日期
手写最简单rxjava,没有实现线程切换,帮助理解rxjava是如何自我调用的
DMRxjava.zip
内容介绍
package com.dming.dmrxjava; import android.os.Bundle; import android.support.annotation.NonNull; import android.support.v7.app.AppCompatActivity; import android.view.View; import android.widget.TextView; public class MainActivity extends AppCompatActivity { int count = 0; TextView msgTv; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); msgTv = (TextView) findViewById(R.id.msgTv); findViewById(R.id.startBtn).setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(ObservableEmitter<String> e) throws Exception { for (int i = 0;i < 10;i++) { e.onNext(String.valueOf(++count)); } } }).subscribe(new Consumer<String>() { @Override public void accept(@NonNull String s) throws Exception { msgTv.setText(s); } }); } }); } }
评论
    相关推荐