RxJava/RxAndroid : buffer(long timespan, TimeUnit unit)-低调大师

RxJava/RxAndroid : buffer(long timespan, TimeUnit unit)

2018-01-18 504

RxJava/RxAndroid : buffer(long timespan, TimeUnit unit)

以timespan个unit时间单位作为缓冲周期，一轮一轮的把数据流中的数据分批发射出去。

import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;

import java.util.List;
import java.util.concurrent.TimeUnit;

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;

public class MainActivity extends AppCompatActivity {
    private String TAG = "输出";

    private Observer<List<Integer>> mObserver = new Observer<List<Integer>>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onNext(List<Integer> list) {
            Log.d(TAG, "onNext");
            for (int i = 0; i < list.size(); i++) {
                Log.d(TAG, "onNext:" + list.get(i));
            }
        }

        @Override
        public void onComplete() {
            Log.d(TAG, "onComplete");
        }

        @Override
        public void onError(Throwable e) {
            Log.e(TAG, e.toString(), e);
        }
    };

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

        Integer[] numbers = new Integer[100];
        for (int i = 0; i < numbers.length; i++) {
            numbers[i] = i;
        }

        Observable.fromArray(numbers)
                .buffer(1, TimeUnit.MILLISECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeWith(mObserver);
    }
}

输出：

01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:0
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:1
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:2
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:3
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:4
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:5
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:6
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:7
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:8
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:9
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:10
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:11
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:12
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:13
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:14
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:15
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:16
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:17
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:18
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:19
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:20
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:21
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:22
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:23
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:24
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:25
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:26
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:27
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:28
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:29
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:30
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:31
01-19 17:12:44.081 21903-21903/zhangphil.book D/输出: onNext:32
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:33
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:34
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:35
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:36
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:37
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:38
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:39
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:40
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:41
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:42
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:43
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:44
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:45
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:46
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:47
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:48
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:49
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:50
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:51
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:52
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:53
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:54
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:55
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:56
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:57
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:58
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:59
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:60
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:61
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:62
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:63
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:64
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:65
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:66
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:67
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:68
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:69
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:70
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:71
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:72
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:73
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:74
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:75
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:76
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:77
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:78
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:79
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:80
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:81
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:82
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:83
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:84
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:85
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:86
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:87
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:88
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:89
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:90
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:91
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:92
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:93
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:94
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:95
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:96
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:97
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:98
01-19 17:12:44.082 21903-21903/zhangphil.book D/输出: onNext:99
01-19 17:12:44.083 21903-21903/zhangphil.book D/输出: onComplete

微信关注我们

原文链接：https://yq.aliyun.com/articles/615732

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Python pyclamad病毒扫描与目录病毒扫描脚本（转载）

Clam AntiVirus(Clam AV)是一个免费而且开放源码的防毒软件，软件与病毒库的更新由开源社区免费发布，目前ClamdAV主要为Linux、Uinux系统提供病毒扫描查杀pyClamad是一个python的第三方模块，可让python直接使用ClamAV病毒扫描守护进程clamd来实现一个高效的病毒检测功能。一、实现集中式的病毒扫描 1、客户端（病毒扫描源）安装clamavp clamd 服务的相关程序包 yum install clamav clamd clamav-update -y chkconfig clamd on 更新病毒库 /usr/bin/freshclam 更改配置文件修改监听地址到所有网络，启动服务 sed -i -e '/^TCPAddr/{ s/127.0.0.1/0.0.0.0/;}' /etc/clamd.conf /etc/init.d/clamd start 2、主控端安装pyClamd模块参考：http://xael.org/pages/pyclamd-en.html pip install pyclamd 验证安装结果： <p...

2018-01-19

615

版权声明：本文为博主原创文章，未经博主允许不得转载。我就看了几天的python。这个作为练习，若有错误，望指出。就是基于socket，每个端口去连一下能返回信息就是开启的。一想这么的没必要。可以去连接，异常出错就是没有开启。 s=socket.socket() s.connect((ip,port)) 但是有的连接要很长时间，那么设置时间： s.settimeout(0.1) 只是ip，没有域名很没意思那么来个域名解析成ip： socket.gethostbyname(Domain) 先不考虑多线程： import socket def getip(Domain): try: return socket.gethostbyname(Domain) except socket.error,e: print '%s: %s'%(Domain,e) return 0 def scan(ip): list1=list() list2=range(1,65535) for port in list2: try: s=socket.socket() s.settimeout(0.1) s.c...

2018-01-19

671

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。