compile 'com.jakewharton:butterknife:7.0.1'compile 'io.reactivex:rxandroid:1.1.0' // RxAndroidcompile 'io.reactivex:rxjava:1.1.0' // 推荐同时加载RxJava

plugins {    id "me.tatarka.retrolambda" version "3.2.4"}android {...    compileOptions {        sourceCompatibility JavaVersion.VERSION_1_8        targetCompatibility JavaVersion.VERSION_1_8    }}

/** * 主Activity, 用于跳转各个模块. * * @author wangchenlong */public class MainActivity extends AppCompatActivity {    @Override    protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.activity_main);    }    // 跳转简单的页面    public void gotoSimpleModule(View view) {        startActivity(new Intent(this, SimpleActivity.class));    }    // 跳转复杂的页面    public void gotoMoreModule(View view) {        startActivity(new Intent(this, MoreActivity.class));    }    // 跳转Lambda的页面    public void gotoLambdaModule(View view) {        startActivity(new Intent(this, LambdaActivity.class));    }    // 跳转网络的页面    public void gotoNetworkModule(View view) {        startActivity(new Intent(this, NetworkActivity.class));    }    // 跳转线程安全的页面    public void gotoSafeModule(View view) {        startActivity(new Intent(this, SafeActivity.class));    }}

    // 观察事件发生    Observable.OnSubscribe mObservableAction = new Observable.OnSubscribe<String>() {        @Override public void call(Subscriber<? super String> subscriber) {            subscriber.onNext(sayMyName()); // 发送事件            subscriber.onCompleted(); // 完成事件        }    };...    // 创建字符串    private String sayMyName() {        return "Hello, I am your friend, Spike!";    }

// 订阅者, 接收字符串, 修改控件Subscriber<String> mTextSubscriber = new Subscriber<String>() {    @Override public void onCompleted() {    }    @Override public void onError(Throwable e) {    }    @Override public void onNext(String s) {        mTvText.setText(s); // 设置文字    }};// 订阅者, 接收字符串, 提示信息Subscriber<String> mToastSubscriber = new Subscriber<String>() {    @Override public void onCompleted() {    }    @Override public void onError(Throwable e) {    }    @Override public void onNext(String s) {        Toast.makeText(SimpleActivity.this, s, Toast.LENGTH_SHORT).show();    }};

@Override protected void onCreate(Bundle savedInstanceState) {    super.onCreate(savedInstanceState);    setContentView(R.layout.activity_simple);    ButterKnife.bind(this);    // 注册观察活动    @SuppressWarnings("unchecked")    Observable<String> observable = Observable.create(mObservableAction);    // 分发订阅信息    observable.observeOn(AndroidSchedulers.mainThread());    observable.subscribe(mTextSubscriber);    observable.subscribe(mToastSubscriber);}

/** * 更多的RxAndroid的使用方法. * <p> * Created by wangchenlong on 15/12/30. */public class MoreActivity extends Activity {    @Bind(R.id.simple_tv_text) TextView mTvText;    final String[] mManyWords = {"Hello", "I", "am", "your", "friend", "Spike"};    final List<String> mManyWordList = Arrays.asList(mManyWords);    // Action类似订阅者, 设置TextView    private Action1<String> mTextViewAction = new Action1<String>() {        @Override public void call(String s) {            mTvText.setText(s);        }    };    // Action设置Toast    private Action1<String> mToastAction = new Action1<String>() {        @Override public void call(String s) {            Toast.makeText(MoreActivity.this, s, Toast.LENGTH_SHORT).show();        }    };    // 设置映射函数    private Func1<List<String>, Observable<String>> mOneLetterFunc = new Func1<List<String>, Observable<String>>() {        @Override public Observable<String> call(List<String> strings) {            return Observable.from(strings); // 映射字符串        }    };    // 设置大写字母    private Func1<String, String> mUpperLetterFunc = new Func1<String, String>() {        @Override public String call(String s) {            return s.toUpperCase(); // 大小字母        }    };    // 连接字符串    private Func2<String, String, String> mMergeStringFunc = new Func2<String, String, String>() {        @Override public String call(String s, String s2) {            return String.format("%s %s", s, s2); // 空格连接字符串        }    };    @Override    protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.activity_simple);        ButterKnife.bind(this);        // 添加字符串, 省略Action的其他方法, 只使用一个onNext.        Observable<String> obShow = Observable.just(sayMyName());        // 先映射, 再设置TextView        obShow.observeOn(AndroidSchedulers.mainThread())                .map(mUpperLetterFunc).subscribe(mTextViewAction);        // 单独显示数组中的每个元素        Observable<String> obMap = Observable.from(mManyWords);        // 映射之后分发        obMap.observeOn(AndroidSchedulers.mainThread())                .map(mUpperLetterFunc).subscribe(mToastAction);        // 优化过的代码, 直接获取数组, 再分发, 再合并, 再显示toast, Toast顺次执行.        Observable.just(mManyWordList)                .observeOn(AndroidSchedulers.mainThread())                .flatMap(mOneLetterFunc)                .reduce(mMergeStringFunc)                .subscribe(mToastAction);    }    // 创建字符串    private String sayMyName() {        return "Hello, I am your friend, Spike!";    }}

// 添加字符串, 省略Action的其他方法, 只使用一个onNext.Observable<String> obShow = Observable.just(sayMyName());// 先映射, 再设置TextViewobShow.observeOn(AndroidSchedulers.mainThread())        .map(mUpperLetterFunc).subscribe(mTextViewAction);

// 单独显示数组中的每个元素Observable<String> obMap = Observable.from(mManyWords);// 映射之后分发obMap.observeOn(AndroidSchedulers.mainThread())        .map(mUpperLetterFunc).subscribe(mToastAction);

// 优化过的代码, 直接获取数组, 再分发, 再合并, 再显示toast, Toast顺次执行.Observable.just(mManyWordList)        .observeOn(AndroidSchedulers.mainThread())        .flatMap(mOneLetterFunc)        .reduce(mMergeStringFunc)        .subscribe(mToastAction);

compile 'com.android.support:recyclerview-v7:23.1.1' // RecyclerViewcompile 'com.squareup.retrofit:retrofit:2.0.0-beta2' // Retrofit网络处理compile 'com.squareup.retrofit:adapter-rxjava:2.0.0-beta2' // Retrofit的rx解析库compile 'com.squareup.retrofit:converter-gson:2.0.0-beta2' // Retrofit的gson库compile 'com.squareup.picasso:picasso:2.5.2' // Picasso网络图片加载

/** * Rx的网络请求方式 * <p> * Created by wangchenlong on 15/12/31. */public class NetworkActivity extends Activity {    @Bind(R.id.network_rv_list) RecyclerView mRvList; // 列表    @Override protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.activity_network);        ButterKnife.bind(this);        // 设置Layout管理器        LinearLayoutManager layoutManager = new LinearLayoutManager(this);        layoutManager.setOrientation(LinearLayoutManager.VERTICAL);        mRvList.setLayoutManager(layoutManager);        // 设置适配器        UserListAdapter adapter = new UserListAdapter(this::gotoDetailPage);        NetworkWrapper.getUsersInto(adapter);        mRvList.setAdapter(adapter);    }    // 点击的回调    public interface UserClickCallback {        void onItemClicked(String name);    }    // 跳转到库详情页面    private void gotoDetailPage(String name) {        startActivity(NetworkDetailActivity.from(NetworkActivity.this, name));    }}

/** * 显示列表 * <p> * Created by wangchenlong on 15/12/31. */public class UserListAdapter extends RecyclerView.Adapter<UserListAdapter.UserViewHolder> {    private List<GitHubUser> mUsers; // 用户名集合    private NetworkActivity.UserClickCallback mCallback; // 用户点击项的回调    public UserListAdapter(NetworkActivity.UserClickCallback callback) {        mUsers = new ArrayList<>();        mCallback = callback;    }    public void addUser(GitHubUser user) {        mUsers.add(user);        notifyItemInserted(mUsers.size() - 1); // 最后一位    }    @Override public UserViewHolder onCreateViewHolder(ViewGroup parent, int viewType) {        View item = LayoutInflater.from(parent.getContext())                .inflate(R.layout.item_network_user, parent, false);        return new UserViewHolder(item, mCallback);    }    @Override public void onBindViewHolder(UserViewHolder holder, int position) {        holder.bindTo(mUsers.get(position));    }    @Override public int getItemCount() {        return mUsers.size();    }    // Adapter的ViewHolder    public static class UserViewHolder extends RecyclerView.ViewHolder {        @Bind(R.id.network_item_iv_user_picture) ImageView mIvUserPicture;        @Bind(R.id.network_item_tv_user_name) TextView mTvUserName;        @Bind(R.id.network_item_tv_user_login) TextView mTvUserLogin;        @Bind(R.id.network_item_tv_user_page) TextView mTvUserPage;        public UserViewHolder(View itemView, NetworkActivity.UserClickCallback callback) {            super(itemView);            ButterKnife.bind(this, itemView);            // 绑定点击事件            itemView.setOnClickListener(v ->                    callback.onItemClicked(mTvUserLogin.getText().toString()));        }        // 绑定数据        public void bindTo(GitHubUser user) {            mTvUserName.setText(user.name);            mTvUserLogin.setText(user.login);            mTvUserPage.setText(user.repos_url);            Picasso.with(mIvUserPicture.getContext())                    .load(user.avatar_url)                    .placeholder(R.drawable.ic_person_black_24dp)                    .into(mIvUserPicture);        }    }    // 用户类, 名称必须与Json解析相同    public static class GitHubUser {        public String login;        public String avatar_url;        public String name;        public String repos_url;    }}

/** * 用户获取类 * <p> * Created by wangchenlong on 15/12/31. */public class NetworkWrapper {    private static final String[] mFamousUsers =            {"SpikeKing", "JakeWharton", "rock3r", "Takhion", "dextorer", "Mariuxtheone"};    // 获取用户信息    public static void getUsersInto(final UserListAdapter adapter) {        GitHubService gitHubService =                ServiceFactory.createServiceFrom(GitHubService.class, GitHubService.ENDPOINT);        Observable.from(mFamousUsers)                .flatMap(gitHubService::getUserData)                .subscribeOn(Schedulers.newThread())                .observeOn(AndroidSchedulers.mainThread())                .subscribe(adapter::addUser);    }    // 获取库信息    public static void getReposInfo(final String username, final RepoListAdapter adapter) {        GitHubService gitHubService =                ServiceFactory.createServiceFrom(GitHubService.class, GitHubService.ENDPOINT);        gitHubService.getRepoData(username)                .flatMap(Observable::from)                .subscribeOn(Schedulers.newThread())                .observeOn(AndroidSchedulers.mainThread())                .subscribe(adapter::addRepo);    }}

/** * 工厂模式 * <p> * Created by wangchenlong on 15/12/31. */public class ServiceFactory {    public static <T> T createServiceFrom(final Class<T> serviceClass, String endpoint) {        Retrofit adapter = new Retrofit.Builder()                .baseUrl(endpoint)                .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) // 添加Rx适配器                .addConverterFactory(GsonConverterFactory.create()) // 添加Gson转换器                .build();        return adapter.create(serviceClass);    }}

/** * GitHub的服务 * <p> * Created by wangchenlong on 15/12/31. */public interface GitHubService {    String ENDPOINT = "https://api.github.com";    // 获取个人信息    @GET("/users/{user}")    Observable<UserListAdapter.GitHubUser> getUserData(@Path("user") String user);    // 获取库, 获取的是数组    @GET("/users/{user}/repos")    Observable<RepoListAdapter.GitHubRepo[]> getRepoData(@Path("user") String user);}

/** * Rx的线程安全 * <p> * Created by wangchenlong on 15/12/31. */public class SafeActivity extends RxAppCompatActivity {    private static final String TAG = "DEBUG-WCL: " + SafeActivity.class.getSimpleName();    @Bind(R.id.simple_tv_text) TextView mTvText;    @Override protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.activity_simple);        ButterKnife.bind(this);        Observable.interval(1, TimeUnit.SECONDS)                .observeOn(AndroidSchedulers.mainThread())                .compose(bindToLifecycle()) // 管理生命周期, 防止内存泄露                .subscribe(this::showTime);    }    private void showTime(Long time) {        mTvText.setText(String.valueOf("时间计数: " + time));        Log.d(TAG, "时间计数器: " + time);    }    @Override    protected void onPause() {        super.onPause();        Log.w(TAG, "页面关闭!");    }}

// RxBindingcompile 'com.jakewharton.rxbinding:rxbinding:0.3.0'compile 'com.jakewharton.rxbinding:rxbinding-appcompat-v7:0.3.0'compile 'com.jakewharton.rxbinding:rxbinding-design:0.3.0'

<?xml version="1.0" encoding="utf-8"?><android.support.design.widget.CoordinatorLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent" android:fitsSystemWindows="true" android:orientation="vertical" tools:context=".BindingActivity">    <android.support.design.widget.AppBarLayout android:layout_width="match_parent" android:layout_height="wrap_content" android:theme="@style/AppTheme.AppBarOverlay">        <android.support.v7.widget.Toolbar android:id="@+id/rxbinding_t_toolbar" android:layout_width="match_parent" android:layout_height="?attr/actionBarSize" android:background="?attr/colorPrimary" android:popupTheme="@style/AppTheme.PopupOverlay" tools:targetApi="21"/>    </android.support.design.widget.AppBarLayout>    <include layout="@layout/content_rxbinding"/>    <android.support.design.widget.FloatingActionButton android:id="@+id/rxbinding_fab_fab" android:layout_width="wrap_content" android:layout_height="wrap_content" android:layout_gravity="bottom|end" android:layout_margin="@dimen/fab_margin" android:src="@android:drawable/ic_dialog_email"/></android.support.design.widget.CoordinatorLayout>

<?xml version="1.0" encoding="utf-8"?><LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent" android:orientation="vertical" android:padding="@dimen/activity_margin" app:layout_behavior="@string/appbar_scrolling_view_behavior" tools:context=".BindingActivity" tools:showIn="@layout/activity_binding">    <TextView android:layout_width="match_parent" android:layout_height="wrap_content" android:text="@string/usual_approach"/>    <EditText android:id="@+id/rxbinding_et_usual_approach" android:layout_width="match_parent" android:layout_height="48dp" android:hint="@null"/>    <TextView android:layout_width="match_parent" android:layout_height="wrap_content" android:text="@string/reactive_approach"/>    <EditText android:id="@+id/rxbinding_et_reactive_approach" android:layout_width="match_parent" android:layout_height="48dp" android:hint="@null"/>    <TextView android:id="@+id/rxbinding_tv_show" android:layout_width="match_parent" android:layout_height="wrap_content"/></LinearLayout>

/** * Rx绑定 * <p> * Created by wangchenlong on 16/1/25. */public class BindingActivity extends AppCompatActivity {    @Bind(R.id.rxbinding_t_toolbar) Toolbar mTToolbar;    @Bind(R.id.rxbinding_et_usual_approach) EditText mEtUsualApproach;    @Bind(R.id.rxbinding_et_reactive_approach) EditText mEtReactiveApproach;    @Bind(R.id.rxbinding_tv_show) TextView mTvShow;    @Bind(R.id.rxbinding_fab_fab) FloatingActionButton mFabFab;    @Override protected void onCreate(@Nullable Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        setContentView(R.layout.activity_binding);        ButterKnife.bind(this);        initToolbar(); // 初始化Toolbar        initFabButton(); // 初始化Fab按钮        initEditText(); // 初始化编辑文本    }    // 初始化Toolbar    private void initToolbar() {        // 添加菜单按钮        setSupportActionBar(mTToolbar);        ActionBar actionBar = getSupportActionBar();        // 添加浏览按钮        if (actionBar != null) {            actionBar.setDisplayHomeAsUpEnabled(true);        }        RxToolbar.itemClicks(mTToolbar).subscribe(this::onToolbarItemClicked);        RxToolbar.navigationClicks(mTToolbar).subscribe(this::onToolbarNavigationClicked);    }    // 点击Toolbar的项    private void onToolbarItemClicked(MenuItem menuItem) {        String m = "点击\"" + menuItem.getTitle() + "\"";        Toast.makeText(this, m, Toast.LENGTH_SHORT).show();    }    // 浏览点击    private void onToolbarNavigationClicked(Void v) {        Toast.makeText(this, "浏览点击", Toast.LENGTH_SHORT).show();    }    @Override public boolean onCreateOptionsMenu(Menu menu) {        getMenuInflater().inflate(R.menu.menu_rxbinding, menu);        return super.onCreateOptionsMenu(menu);    }    // 初始化Fab按钮    private void initFabButton() {        RxView.clicks(mFabFab).subscribe(this::onFabClicked);    }    // 点击Fab按钮    private void onFabClicked(Void v) {        Snackbar snackbar = Snackbar.make(findViewById(android.R.id.content), "点击Snackbar", Snackbar.LENGTH_SHORT);        snackbar.show();        RxSnackbar.dismisses(snackbar).subscribe(this::onSnackbarDismissed);    }    // 销毁Snackbar, event参考{Snackbar}    private void onSnackbarDismissed(int event) {        String text = "Snackbar消失代码:" + event;        Toast.makeText(this, text, Toast.LENGTH_SHORT).show();    }    // 初始化编辑文本    private void initEditText() {        // 正常方式        mEtUsualApproach.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) {                mTvShow.setText(s);            }            @Override public void afterTextChanged(Editable s) {            }        });        // Rx方式        RxTextView.textChanges(mEtReactiveApproach).subscribe(mTvShow::setText);    }}