一、描述

toMap收集原始Observable发射的所有数据项到一个Map（默认是HashMap）然后发射这个Map。

你可以提供一个用于生成Map的Key的函数，还可以提供一个函数转换数据项到Map存储的值（默认数据项本身就是值）。

toMap默认不在任何特定的调度器上执行。

二、示意图

toMap

三、示例代码

class Student {
    private int id;
    private String name;

    public Student(int id, String name) {
        this.id = id;
        this.name = name;
    }

    public int getId() {
        return id;
    }

    public String getName() {
        return name;
    }

    @Override
    public String toString() {
        return "Student{" +
                "id=" + id +
                ", name='" + name + '\'' +
                '}';
    }
}

Student stu1 = new Student(1001, "ZhangSan");
Student stu2 = new Student(1002, "LiSi");

Observable.just(stu1, stu2).toMap(new Func1<Student, Integer>() {
    @Override
    public Integer call(Student student) {
        return student.getId();
    }
}).subscribe(new Subscriber<Map<Integer, Student>>() {
    @Override
    public void onCompleted() {
        System.out.println("onCompleted.");
    }

    @Override
    public void onError(Throwable e) {
        System.out.println("onError: " + e.getMessage());
    }

    @Override
    public void onNext(Map<Integer, Student> map) {
        System.out.println("onNext: " + map.toString());
    }
});