Skip 抑制Observable发射的前N项数据 使用Skip操作符,你可以忽略Observable’发射的前N项数据,只保留之后的数据。 RxJava中这个操作符叫skip。skip的这个变体默认不在任何特定的调度器上执行。 Javadoc: skip(int)) skip的这个变体接受一个时长而不是数量参数。它会丢弃原始Observable开始的那段时间发射的数据,时长和时间单位通过参数指定
Sample 定期发射Observable最近发射的数据项 Sample操作符定时查看一个Observable,然后发射自上次采样以来它最近发射的数据。 在某些实现中,有一个ThrottleFirst操作符的功能类似,但不是发射采样期间的最近的数据,而是发射在那段时间内的第一项数据。 RxJava将这个操作符实现为sample和throttleLast。 注意:如果自上次采样以来,原始Observ
Last 只发射最后一项(或者满足某个条件的最后一项)数据 如果你只对Observable发射的最后一项数据,或者满足某个条件的最后一项数据感兴趣,你可以使用Last操作符。 在某些实现中,Last没有实现为一个返回Observable的过滤操作符,而是实现为一个在当时就发射原始Observable指定数据项的阻塞函数。在这些实现中,如果你想要的是一个过滤操作符,最好使用TakeLast(1)。
IgnoreElements 不发射任何数据,只发射Observable的终止通知 IgnoreElements操作符抑制原始Observable发射的所有数据,只允许它的终止通知(onError或onCompleted)通过。 如果你不关心一个Observable发射的数据,但是希望在它完成时或遇到错误终止时收到通知,你可以对Observable使用ignoreElements操作符,它会确保永
First 只发射第一项(或者满足某个条件的第一项)数据 如果你只对Observable发射的第一项数据,或者满足某个条件的第一项数据感兴趣,你可以使用First操作符。 在某些实现中,First没有实现为一个返回Observable的过滤操作符,而是实现为一个在当时就发射原始Observable指定数据项的阻塞函数。在这些实现中,如果你想要的是一个过滤操作符,最好使用Take(1)或者Eleme
Filter 只发射通过了谓词测试的数据项 Filter操作符使用你指定的一个谓词函数测试数据项,只有通过测试的数据才会被发射。 RxJava将这个操作符实现为filter函数。 示例代码 Observable.just(1, 2, 3, 4, 5) .filter(new Func1<Integer, Boolean>() { @Override
ElementAt 只发射第N项数据 ElementAt操作符获取原始Observable发射的数据序列指定索引位置的数据项,然后当做自己的唯一数据发射。 RxJava将这个操作符实现为elementAt,给它传递一个基于0的索引值,它会发射原始Observable数据序列对应索引位置的值,如果你传递给elementAt的值为5,那么它会发射第六项的数据。 如果你传递的是一个负数,或者原始Obse
Distinct 抑制(过滤掉)重复的数据项 Distinct的过滤规则是:只允许还没有发射过的数据项通过。 在某些实现中,有一些变体允许你调整判定两个数据不同(distinct)的标准。还有一些实现只比较一项数据和它的直接前驱,因此只会从序列中过滤掉连续重复的数据。 distinct() RxJava将这个操作符实现为distinct函数。 示例代码 Observable.just(1, 2,
Debounce 仅在过了一段指定的时间还没发射数据时才发射一个数据 Debounce操作符会过滤掉发射速率过快的数据项。 RxJava将这个操作符实现为throttleWithTimeout和debounce。 注意:这个操作符会会接着最后一项数据发射原始Observable的onCompleted通知,即使这个通知发生在你指定的时间窗口内(从最后一项数据的发射算起)。也就是说,onComple
这个页面展示的操作符可用于过滤和选择Observable发射的数据序列。 filter( ) — 过滤数据 takeLast( ) — 只发射最后的N项数据 last( ) — 只发射最后的一项数据 lastOrDefault( ) — 只发射最后的一项数据,如果Observable为空就发射默认值 takeLastBuffer( ) — 将最后的N项数据当做单个数据发射 skip( ) — 跳过
有时候,我们可能会希望在远程过程调用中对通讯的一些细节有更多的控制,比如对传输中的数据进行加密、压缩、签名、跟踪、协议转换等等,但是又希望这些工作能够跟服务函数/方法本身可以解耦。这个时候,Hprose 过滤器就是一个不错的选择。 Hprose 过滤器是一个接口,它有两个方法: inputFilter(data, context) outputFilter(data, context) 其中 i
缓存 filter.http.Buffer 故障注入 filter.http.FaultAbort filter.http.HTTPFault 健康检查 filter.http.HealthCheck Lua filter.http.Lua 速率限制 filter.http.RateLimit 路由 filter.http.Router gRPC-JSON转码器 filter.http.GrpcJ
Cors过滤器的配置概述。 { "name": "cors", "config": {} } 返回 上一级
缓存 CORS过滤器 DynamoDB 故障注入 配置 中止 时延 gRPC HTTP/1.1 桥接 gRPC-JSON 转码过滤器 gRPC-JSON转码器配置 gRPC-Web 过滤器 健康检查 Lua 速率限制 路由 返回 上一级
这是一个基于路由或虚拟主机的处理跨源共享资源请求(Cross-Origin Resource Sharing)的过滤器设置。标题相关的含义,请参阅下面的连接。 https://developer.mozilla.org/en-US/docs/Web/HTTP/Access_control_CORS https://www.w3.org/TR/cors/ v1 API 参考 v2 API 参考 返回