專案rxjava+rxandroid學習

阿新 • • 發佈：2019-01-27

1、寫法1

/**
         * 列印helloworld，使用被觀察者和訂閱者
         * 被觀察者發出事件資訊
         * 訂閱者處理事件
         */
        Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {
            @Override
            public void call(Subscriber<? super String> subscriber) {
                subscriber.onNext("hello world" 
);
                subscriber.onCompleted();
            }
        });

        Subscriber<String> subscriber = new Subscriber<String>() {
            @Override
            public void onCompleted() {
                Log.i("subscriber", "complete");
            }

            @Override
            public 
 void onError(Throwable e) {

            }

            @Override
            public void onNext(String s) {
                Log.i("subscriber", s);
            }
        };
        observable.subscribe(subscriber);

2、寫法2

    /**
         * 使用map來進行物件的轉化，個人理解map的用法相當於介面卡，將輸入的結果轉化成想要得到的結果
         */ 


        Observable.just("hello").map(new Func1<String, String>() {
            @Override
            public String call(String s) {
                return s+" wrold";
            }
        }).subscribe(new Action1<String>() {
            @Override
            public void call(String s) {
                Log.i("test",s);
            }
        });

3、寫法3

Pet.java
public class Pet {
private String Petname;

public Pet(String petname) {
    Petname = petname;
}

public String getPetname() {
    return Petname;
}

public void setPetname(String petname) {
    Petname = petname;
}
}
Master.java
public class Master {
private String name;
private List<Pet> petList=new ArrayList<Pet>();

public String getName() {
    return name;
}

public void setName(String name) {
    this.name = name;
}

public List<Pet> getPetList() {
    return petList;
}

public void setPetList(List<Pet> petList) {
    this.petList = petList;
}
}

/**
     * 使用flatmap來進行一對多的物件轉化
     */

    List<Master> masterList=new ArrayList<Master>();
    for(int i=0;i<3;i++)
    {
        Master master=new Master();
        master.setName("master"+i);
        for(int j=0;j<3;j++)
        {
            master.getPetList().add(new Pet("pet"+j));
        }
        masterList.add(master);
    }
    for (Master item:
         masterList) {
        Log.i("item",item.getName());
    }

    Observable.from(masterList).flatMap(new Func1<Master, Observable<Pet>>() {
        @Override
        public Observable<Pet> call(Master master) {
            return Observable.from(master.getPetList());
        }
    }).subscribe(new Subscriber<Pet>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(Pet pet) {
            Log.i("PetName",pet.getPetname());
        }
    });

自己寫的demo：

package com.lcwr.android.modules.home.activity;

import android.app.Activity;
import android.os.Bundle;
import android.os.PersistableBundle;
import android.support.annotation.Nullable;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

import com.lcwr.android.R;
import com.xitaiinfo.library.commons.rx.Rx;

import java.util.ArrayList;
import java.util.List;

import butterknife.BindView;
import butterknife.ButterKnife;
import butterknife.Unbinder;
import rx.Observable;
import rx.Subscriber;
import rx.functions.Action1;
import rx.functions.Func1;

/**
 * author: lihui
 * version: 1.0
 * date: on 2017/8/4
 * time：on 16:37
 * 描述：
 */

public class Testactivity extends Activity {
    Unbinder unbinder;
    @BindView(R.id.tv)
    TextView mTv;
    @BindView(R.id.button)
    Button bt;

    @Override
    public void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        setContentView(R.layout.test);
        unbinder = ButterKnife.bind(this);
        List<Master> masterList = new ArrayList<>();
        for (int i = 0; i < 5; i++) {
            Master master = new Master("master" + i);
            for (int j = 0; j < 3; j++) {//每個人3個寵物
                Pet pet = new Pet(master.getMastername() + "-pet" + j);
                master.getPetList().add(pet);
            }
            masterList.add(master);//5個人
        }
        for (Master m : masterList) {
            Log.d("lihui", "master m---   " + m.toString());

        }
     //   Observable ob = Observable.from(masterList).map(new Func1<Master, Object>() {
//            @Override
//            public Object call(Master master) {
//                Log.d("lihui", "master---   " + master.toString());
//
//                return master.getPetList();
//            }
//        });
        Observable ob = Observable.from(masterList).flatMap(new Func1<Master, Observable<Pet>>() {
            @Override
            public Observable<Pet> call(Master master) {
                Log.d("lihui", "master---   " + master.toString());

                return Observable.from(master.getPetList());
            }
        });

        Action1 action1 = new Action1<Pet>() {
            @Override
            public void call(Pet pet) {
                Log.d("lihui", "p---   " + pet.toString());
//                List<Pet> petlist = (List<Pet>) o;
//                for (Pet p : petlist) {
//                    Log.d("lihui", "p---   " + p.toString());
//                }
            }
        };

        Rx.click(bt, new Action1<Void>() {
            @Override
            public void call(Void aVoid) {
                ob.subscribe(action1);
            }
        });
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if (unbinder != null)
            unbinder.unbind();
    }

    class Master {
        public Master(String name) {
            this.mastername = name;
        }

        @Override
        public String toString() {
            return "Master{" +
                    "mastername='" + mastername + '\'' +
                    ", petList=" + petList +
                    '}';
        }

        public String getMastername() {
            return mastername;
        }

        public void setMastername(String mastername) {
            this.mastername = mastername;
        }

        String mastername;

        public List<Pet> getPetList() {
            return petList;
        }


        List<Pet> petList = new ArrayList<>();

    }

    class Pet {
        public String getPetname() {
            return petname;
        }

        public void setPetname(String petname) {
            this.petname = petname;
        }

        public Pet(String petname) {
            this.petname = petname;
        }

        @Override
        public String toString() {
            return "Pet{" +
                    "petname='" + petname + '\'' +
                    '}';
        }

        String petname;
    }
}


列印：

1、
Observable.from(masterList).flatMap(new Func1<Master, Observable<Pet>>()

對應----
 new Action1<Pet>() {
            @Override
            public void call(Pet pet) {
}

1 Master call --- 3次Action1 call
列印：
08-04 18:29:19.036 14475-14475/com.lcwr.android D/lihui: master---   Master{mastername='master0', petList=[Pet{petname='master0-pet0'}, Pet{petname='master0-pet1'}, Pet{petname='master0-pet2'}]}
08-04 18:29:19.040 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master0-pet0'}
08-04 18:29:19.040 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master0-pet1'}
08-04 18:29:19.040 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master0-pet2'}
08-04 18:29:19.040 14475-14475/com.lcwr.android D/lihui: 

master---   Master{mastername='master1', petList=[Pet{petname='master1-pet0'}, Pet{petname='master1-pet1'}, Pet{petname='master1-pet2'}]}
08-04 18:29:19.041 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master1-pet0'}
08-04 18:29:19.041 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master1-pet1'}
08-04 18:29:19.041 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master1-pet2'}
08-04 18:29:19.041 14475-14475/com.lcwr.android D/lihui: 

master---   Master{mastername='master2', petList=[Pet{petname='master2-pet0'}, Pet{petname='master2-pet1'}, Pet{petname='master2-pet2'}]}
08-04 18:29:19.041 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master2-pet0'}
08-04 18:29:19.041 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master2-pet1'}
08-04 18:29:19.042 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master2-pet2'}
08-04 18:29:19.042 14475-14475/com.lcwr.android D/lihui: 

master---   Master{mastername='master3', petList=[Pet{petname='master3-pet0'}, Pet{petname='master3-pet1'}, Pet{petname='master3-pet2'}]}
08-04 18:29:19.042 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master3-pet0'}
08-04 18:29:19.042 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master3-pet1'}
08-04 18:29:19.042 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master3-pet2'}
08-04 18:29:19.043 14475-14475/com.lcwr.android D/lihui: 

master---   Master{mastername='master4', petList=[Pet{petname='master4-pet0'}, Pet{petname='master4-pet1'}, Pet{petname='master4-pet2'}]}
08-04 18:29:19.043 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master4-pet0'}
08-04 18:29:19.043 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master4-pet1'}
08-04 18:29:19.043 14475-14475/com.lcwr.android D/lihui: p---   Pet{petname='master4-pet2'}

錯誤

        Observable ob = Observable.from(masterList).map(new Func1<Master, Observable<Pet>>() {}

new Action1<Pet>() {
            @Override
            public void call(Pet pet) {}}

                                                                   Caused by: java.lang.ClassCastException: rx.Observable cannot be cast to com.lcwr.android.modules.home.activity.Testactivity$Pet

修改map

        Observable ob = Observable.from(masterList).map(new Func1<Master, List<Pet>>() {}

----

new Action1<List<Pet>>() {
            @Override
            public void call(List<Pet> petList) {
                Log.d("lihui", "petList---   " + petList.toString());}}


列印： 1-1
map 1 ---   Action1 1
08-04 18:34:29.230 21992-21992/com.lcwr.android D/lihui: master---   Master{mastername='master0', petList=[Pet{petname='master0-pet0'}, Pet{petname='master0-pet1'}, Pet{petname='master0-pet2'}]}
08-04 18:34:29.230 21992-21992/com.lcwr.android D/lihui: petList---   [Pet{petname='master0-pet0'}, Pet{petname='master0-pet1'}, Pet{petname='master0-pet2'}]
08-04 18:34:29.230 21992-21992/com.lcwr.android D/lihui: master---   Master{mastername='master1', petList=[Pet{petname='master1-pet0'}, Pet{petname='master1-pet1'}, Pet{petname='master1-pet2'}]}
08-04 18:34:29.230 21992-21992/com.lcwr.android D/lihui: petList---   [Pet{petname='master1-pet0'}, Pet{petname='master1-pet1'}, Pet{petname='master1-pet2'}]
08-04 18:34:29.231 21992-21992/com.lcwr.android D/lihui: master---   Master{mastername='master2', petList=[Pet{petname='master2-pet0'}, Pet{petname='master2-pet1'}, Pet{petname='master2-pet2'}]}
08-04 18:34:29.231 21992-21992/com.lcwr.android D/lihui: petList---   [Pet{petname='master2-pet0'}, Pet{petname='master2-pet1'}, Pet{petname='master2-pet2'}]
08-04 18:34:29.231 21992-21992/com.lcwr.android D/lihui: master---   Master{mastername='master3', petList=[Pet{petname='master3-pet0'}, Pet{petname='master3-pet1'}, Pet{petname='master3-pet2'}]}
08-04 18:34:29.231 21992-21992/com.lcwr.android D/lihui: petList---   [Pet{petname='master3-pet0'}, Pet{petname='master3-pet1'}, Pet{petname='master3-pet2'}]
08-04 18:34:29.231 21992-21992/com.lcwr.android D/lihui: master---   Master{mastername='master4', petList=[Pet{petname='master4-pet0'}, Pet{petname='master4-pet1'}, Pet{petname='master4-pet2'}]}
08-04 18:34:29.231 21992-21992/com.lcwr.android D/lihui: petList---   [Pet{petname='master4-pet0'}, Pet{petname='master4-pet1'}, Pet{petname='master4-pet2'}]

同時看出

from 產生事件是一次傳送一個事件！！！

flatmap 相當於迴圈2次，開始一次迴圈，內部再迴圈一次！！！

專案rxjava+rxandroid學習

1、寫法1 /** * 列印helloworld，使用被觀察者和訂閱者 * 被觀察者發出事件資訊 * 訂閱者處理事件 */ Observable<String&g

RxJava的學習與實現

導致 sdi onerror isp create complete 用處配置人的 RxJava 要在Android中使用RxJava2, 先添加Gradle配置: compile ‘io.reactivex.rxjava2:rxjava:2.0.1‘

Android Rxjava的學習

1.定義 Rxjava由於其基於事件流的鏈式呼叫、邏輯簡潔 & 使用簡單的特點，深受各大 Android開發者的歡迎。 RxJava 是一個在 Java VM 上使用可觀測的序列來組成非同步的、基於事件的程式的庫。 RxJava用於非同步執行任務，跟建立子執行緒執行任務

RxJava RxAndroid RxLifecycle基本使用（使用Kotlin語言）

簡介 RxJava是基於響應式程式設計的框架，響應式程式設計的思想就是一個事件發生後，監聽著這個事件的監聽器馬上做出響應。類似於平常的開關燈。當我們開啟燈的開關時，燈馬上亮了；當我們關閉燈的開關時，燈馬上熄了。這個過程中，燈對我們控制開關的事件做出了響應。在Android中，設定按鈕監聽

【機器人學】機器人開源專案KDL原始碼學習：（8）KDL的精髓

首先說一下我的心得： 1. 我認為KDL的精髓是Spatial Vector，結合C++等面向物件的語言可以寫出較好的軟體。 2. 直接閱讀KDL程式碼不適合初學者學習機械臂動力學。 3. 要學習機械臂動力學的話應首先閱讀使用3維向量推導公式的文獻，也就是線速度和角速度獨立分析

【機器人學】機器人開源專案KDL原始碼學習：（4）機械臂逆動力學的牛頓尤拉演算法

機械臂的逆動力學問題可以認為是：已知機械臂各個連桿的關節的運動（關節位移、關節速度和關節加速度），求產生這個加速度響應所需要的力/力矩。KDL提供了兩個求解逆動力學的求解器，其中一個是牛頓尤拉法，這個方法是最簡單和高效的方法。牛頓尤拉法演算法可以分為三個步驟： step1：

【機器人學】機器人開源專案KDL原始碼學習：（6）笛卡爾空間軌跡規劃、圓弧過渡、姿態插值、梯形速度、pathlength

本文的內容是對另一篇文章（連結）的補充，對Trajectory_example.cpp涉及到的原理作一些簡單的講解，主要內容是：（1）機器人路徑規劃圓弧過渡的原理；（2）機器人路徑規劃梯形波的原理；（3）機器人末端姿態插值的方法（角-軸）；（4）KDL

【機器人學】機器人開源專案KDL原始碼學習：（7）examples中的CMakeList.txt檔案解讀

通過學習KDL開源專案的程式碼可以學習CMake構建程式的知識，現簡單介紹一下orocos_kinematics_dynamics-master\orocos_kinematics_dynamics-master\orocos_kdl\examples\CMakeList.txt檔案的指令。

【機器人學】機器人開源專案KDL原始碼學習：（5）KDL如何求解幾何雅克比矩陣

這篇文章試圖說清楚兩件事：1. 幾何雅克比矩陣的本質；2. KDL如何求解機械臂的幾何雅克比矩陣。一、幾何雅克比矩陣的本質機械臂的關節空間的速度可以對映到執行器末端在操作空間的速度，這種對映可以通過一個矩陣來描述，就是幾何雅克比矩陣，瞭解雅克比矩陣需要了解這種對映關係的本質，這

【機器人學】機器人開源專案KDL原始碼學習：（3）機器人操作空間路徑規劃(Path Planning)和軌跡規劃（Trajectory Planning）示例

很多同學會把路徑規劃(Path Planning)和軌跡規劃（Trajectory Planning）這兩個概念混淆，路徑規劃只是表示了機械臂末端在操作空間中的幾何資訊，比如從工作臺的一端（A點）沿直線移動到另一端（B點）。而軌跡規劃則加上了時間律，比如它要完成的任務是從A點開始到B點結束，中間

IDEA JSP專案構建及學習心得

近期學習的東西比較雜亂，導致了很多東西都有些忘卻。在這裡記錄一份心得。簡而言之JSP也就是Java程式碼在頁面上的一種呈現方式，用於Web專案的前臺展示。在這裡不做過多的闡述。 MVC設計模式，Servlet充當的是控制器，控制專案的顯示 M 模型 V 檢視。專案暫時

零基礎入門到專案開發java學習線路圖

對於Java程式設計師而言，紮實的基礎是不可或缺的，基礎的牢固程度決定了Java這條路你能走多遠，所以要掌握並精通Java基礎知識。無論你是通過自學走上Java道路的還是通過培訓來進行轉型的，對於Java程式設計師而言技術和好的程式設計習慣都是很重要的！在Java中，面

專案也可以學習到很多東西

今天分享關於最近做的一個小專案學習一些感悟。 1.小專案也能學習到非常多的知識最近做的是一個數據整理的一個專案，後臺系統需要一些統計的資料，如果從原有的系統中查詢，會大大影響到其他端的效能，而且相對於手機端去直接使用者，後臺系統面對的是公司人員和運營人員，使用者量少，但是查詢的資料確不少，需要做大量的計算，

資訊系統專案管理師-學習筆記與複習資料

一、前言年初的時候就決定要今年考一下軟考高階和PMP，然而由於換工作等原因（太貴了o(╥﹏╥)o），PMP最後還是沒有報名，報名了11月份的資訊專案管理師考試（以下簡稱高項），本文僅僅把我複習考試的經歷和方法記錄下來，以供大家參考。二、複習資料 2.1

Androif Rxjava+RxAndroid+ReTrofit2+okHttp3使用

在 app 的 build.gradle 中 dependencies{ / /網路請求框架Rxjava+RxAndroid+ReTrofit2+okHttp3+RxBinding //匯入retrofit implementation '

Android RxJava/RxAndroid結合Retrofit使用

概述 RxJava是一個在 Java VM 上使用可觀測的序列來組成非同步的、基於事件的程式的庫。更重要的是：使用RxJava在程式碼邏輯上會非常簡潔明瞭，尤其是在複雜的邏輯上。告別迷之縮排。 RxAndroid是RxJava針對Android平臺的拓展。

小專案網上商城學習心得

只對這個專案的功能以及用到的技術進行分析和總結： 1.使用者註冊:引用了jQuery Validate的表單校驗，功能很多，還能結合ajax實現自定義表單校驗，註冊成功還加入了郵件啟用功能！主要技術有：jquery,ajax.

21個專案-MNIST機器學習入門

機器學習實現手寫數字識別： from tensorflow.examples.tutorials.mnist import input_data import tensorflow as tf mnist=input_data.read_data_sets('MNIST_data/',one_hot=

想用rxjava+rxandroid 替換handle實現數字時鐘，出現無響應，不能隔一秒呼叫onNext

package com.example.testrxandroid; import rx.Observable; import rx.Observable.OnSubscribe; import rx.android.schedulers.AndroidS

孫宇老師 SyPro專案部署成功學習筆記

SyPro專案部署（下載 yu共享檔案\SYPRO示例專案），用的是MyEclipse for Spring 10 和MyEclipse 10 ，但是有報錯；執行不了，後給孫老師郵件，說明是用eclipse開發。開發工具： eclipse-standard-kepl

專案rxjava+rxandroid學習

相關推薦