摘要：变换操作摘抄自文档中文翻译对序列的每一项都应用一个函数来变换发射的数据序列将发射的数据集合变换为集合，然后将这些发射的数据平坦化的放进一个多带带的对发射的每一项数据应用一个函数，然后按顺序依次发射每一个值将分拆为集合，将原始发射的数据按分组，
变换操作
摘抄自Reactive X文档中文翻译
map 对序列的每一项都应用一个函数来变换Observable发射的数据序列
flatmap 将Observable发射的数据集合变换为Observables集合，然后将这些Observable发射的数据平坦化的放进一个多带带的Observable
scan 对Observable发射的每一项数据应用一个函数，然后按顺序依次发射每一个值
groupBy 将Observable分拆为Observable集合，将原始Observable发射的数据按Key分组，每一个Observable发射一组不同的数据
buffer 它定期从Observable收集数据到一个集合，然后把这些数据集合打包发射，而不是一次发射一个
window 定期将来自Observable的数据分拆成一些Observable窗口，然后发射这些窗口，而不是每次发射一项
map
map 对序列的每一项都应用一个函数来变换Observable发射的数据序列
//比如将每个字符串拼接上
from magicer
String[] str = {"winter is coming","the king in the north"};
Observable.from(str).map(new Func1() {
@Override
public String call(String s) {
return s+"
from magicer";
}
}).subscribe(new Action1() {
@Override
public void call(String s) {
Log.i(TAG, "call: "+s);
}
});
}
flatmap
flatmap 将Observable发射的数据集合变换为Observables集合，然后将这些Observable发射的数据平坦化的放进一个多带带的Observable
//这里的nickName是个List
Observable.from(mStudents).flatMap(new Func1>() {
@Override
public Observable call(Student student) {
return Observable.from(student.getNickNames());
}
}).subscribe(new Action1() {
@Override
public void call(String s) {
Log.i(TAG, "call: "+s);
}
});
scan
scan 对Observable发射的每一项数据应用一个函数，然后按顺序依次发射每一个值
Observable.just(1,2,3,4,5).scan(new Func2() {
@Override
public Integer call(Integer integer, Integer integer2) {
return integer+integer2;
}
}).subscribe(new Action1() {
@Override
public void call(Integer integer) {
Log.i(TAG, "call: "+integer);
}
});
groupby
groupBy 将Observable分拆为Observable集合，将原始Observable发射的数据按Key分组，每一个Observable发射一组不同的数据
Observable.interval(1, TimeUnit.SECONDS).groupBy(new Func1() {
@Override
public Long call(Long aLong) {
return aLong %2;
}
}).subscribe(new Action1>() {
@Override
public void call(final GroupedObservable result) {
result.subscribe(new Action1() {
@Override
public void call(Long aLong) {
Log.i(TAG, "groupby call: "+aLong+" getKey:"+result.getKey());
}
});
}
});
buffer
buffer 它定期从Observable收集数据到一个集合，然后把这些数据集合打包发射，而不是一次发射一个
Observable.interval(1,TimeUnit.SECONDS)
.buffer(3,TimeUnit.SECONDS)
.subscribe(new Action1>() {
@Override
public void call(List longs) {
Log.i(TAG, "call: "+longs);
}
});
window
window 定期将来自Observable的数据分拆成一些Observable窗口，然后发射这些窗口，而不是每次发射一项
Window和Buffer类似，但不是发射来自原始Observable的数据包，它发射的是Observables，这些Observables中的每一个都发射原始Observable数据的一个子集，最后发射一个onCompleted通知。
Observable.interval(1,TimeUnit.SECONDS)
.window(3,TimeUnit.SECONDS)
.subscribe(new Action1>() {
@Override
public void call(final Observable longObservable) {
longObservable.subscribe(new Action1() {
@Override
public void call(Long aLong) {
Log.i(TAG, "call: "+aLong);
}
});
}
});
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/13540.html
