RxJava操作符实践:2_变换操作之1_map

一、描述

对Observable发射的每一项数据应用一个函数,执行变换操作。

Map操作符对原始Observable发射的每一项数据应用一个你选择的函数,然后返回一个发射这些结果的Observable。

这个操作符默认不在任何特定的调度器上执行。

二、示意图

map

三、示例代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
class Student {
private String name;

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

public String getName() {
return name;
}
}

Student student1 = new Student("ZhangSan");
Student student2 = new Student("LiSi");
Student student3 = new Student("WangWu");

Observable.just(student1, student2, student3)
.map(new Func1<Student, String>() {
@Override
public String call(Student student) {
return student.getName();
}
})
.subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
System.out.println("onCompleted.");
}

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

@Override
public void onNext(String s) {
System.out.println("onNext: " + s);
}
});

四、运行结果

1
2
3
4
onNext: ZhangSan
onNext: LiSi
onNext: WangWu
onCompleted.

项目代码已上传到Github:https://github.com/SherlockShi/RxJavaBestPractise

五、更多

跟map相关的操作符还有:

  • cast
  • encode
  • byLine

详情可查阅下面的参考资料。

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

感谢你的支持,让我继续努力分享有用的技术和知识点!