首页 > TAG信息列表 > onNext

Rxjava使用手册

创建Observables https://github.com/ReactiveX/RxJava/wiki/Creating-Observables#create 1:Observable.fromAction使用效果: Observable<Integer> observable = Observable.fromAction( () -> { System.out.println("我去,被执行了&

Spring 响应式编程 随记 -- C2 Spring 响应式编程基本概念 (二)

【 好书分享:《Spring 响应式编程》-- 京东】 2.2 使用 RxJava 响应式框架的实践 RxJava 库 是 Reactive Extensions 的 Java虚拟机实现,近似于观察者模式,迭代器模式,函数式编程的组合。 2.2.1 响应式流 = 观察者 + 迭代器 通过事件分离生产者和消费者。 迭代器模式:不希望生产

rxjava

前言:阳光总在风雨后,人生没有白吃的苦,也没有白走的路,要知道,你现在吃的苦,现在受的伤,会成为日后的徽章。 一、概述 提高开发效果,降低维护成本一直是团队追求的宗旨。现在安卓里面RxJava2+Retrofit+OKHttp的网络请求框架是最流行的,几乎一统江湖,配合响应式式编程的RxJava使用也越来

iOS逆向之代码注入!(下)

本文主要是以WeChat为例,讲解如何破坏WeChat注册、以及如何获取登录密码引子在进行WeChat实践操作时,首先需要了解一个概念:Method Swizzing(即方法交换)Method Swizzing(即方法交换)是利用OC的Runtime特性,动态改变SEL(方法编号)和IMP(方法实现)的对应关系,达到OC方法调用流程改变的目的,主要用

RxJava的四种Subjects:PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解

RxJava的四种Subjects:PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解 Subject:它既是Observable,又是observer。也就是既可以发送事件,也可以接收事件。 下面是四个子类PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的区别: PublishSubje

RxJava2详细攻略(上)

0.简介 RxJava其实就是提供一套异步编程的API,这套API是基于观察者模式的,而且是链式调用的,所以使用RxJava编写的代码的逻辑会非常简介。 RxJava有三个基本元素: 1.被观察者(Observable) 2.观察者(Observer) 3.订阅(subscribe) 下面来说说以上三者是如何写作的: 首先在gradle文件中添

iOS逆向--方法交换的几种方式以及破坏微信注册

作者:海浪宝宝 链接:https://juejin.cn/post/6876355054236860429 hook注册按钮 获取target和action 首先我们拿到wechat包放到重签名工程的APP目录中,然后真机运行,运行后我们点击Debug view Hierarchy按钮,也就是下面按钮 旋转一下,然后我们看到我们可以拿到当前页面的图层层级

RxJava、RxBus学习

定义:一个基于事件流的实现异步操作的库 特点:基于事件流的链式调用、逻辑简洁 & 使用简单 作用:实现异步操作,类似于AsynTask、Handler   使用介绍: 步骤1:创建Observable(被观察者),并生产事件 // 1. 创建被观察者 Observable 对象 Observable<Integer> observable =

8-10 ObserveableCommand演示

创建类继承HystrixObservableCommand泛型是String 重写里面方法。 返回的类型就是 Observable,返回的就是它 初始化name属性和构造方法 这是哦我们讲隔离的时候,会用到的东西,为了减少那时候的代码量,所以这里提前做个预留, 那么我们返回呢?要返回Observable<String> 要返回它肯定

Observable & Observer 既是可监听序列也是观察者

Observable & Observer 既是可监听序列也是观察者 有一部分非常特别的序列。它们既是可监听序列也是观察者 textField的当前文本。它可以看成是由用户输入,而产生的一个文本序列。也可以是由外部文本序列,来控制当前显示内容的观察者: // 作为可监听序列 let observable = textField

rxjava介绍

  Github https://github.com/ReactiveX/RxJava https://github.com/ReactiveX/RxAndroid 引入依赖 compile 'io.reactivex:rxjava:1.0.14' compile 'io.reactivex:rxandroid:1.0.1' 二.RxJava是什么 RxJava是一个在 Java VM 上使用可观测的序列来组成异步的、基于事件

手把手带你入门神秘的RxJava

1.什么是RxJava• Rx是Reactive Extensions的简写,翻译为响应的扩展。也就是通过由一方发出信息,另一方响应信息并作出处理的核心框架代码。• 该框架由微软的架构师Erik Meijer领导的团队开发,并在2012年11月开源。• Rx库支持.NET、JavaScript和C++等,现在已经支持几乎全部的流

一文带你全面了解RxJava

工作需要,刚好在学习 RxJava网络请求框架,网上搜了一些 关于RxJava 的教程,但都并不是很好理解,所幸最后找到了几篇有助于初学者了解 RxJava 的文章,于是结合自己的理解,重新整理成一篇发给大家,希望通过我的咀嚼,能够帮助大家更快的了解和上手 RxJava,话不多说,进入正文吧! 1.什么是RxJava•

Operation之其他实用操作符

delay 该操作符会将 Observable 的所有元素都先拖延一段设定好的时间, 然后才将他们发送出来 Observable.of(1,2,3,4) .delay(5, scheduler: MainScheduler.instance) .subscribe(onNext: { print($0) }) .disposed(by: bag) delaySubscription 该操作符可以进行

Operation之变换操作符

buffer buffer方法的作用是缓冲组合, 第一个参数是缓冲时间, 第二个参数是缓冲个数, 第三个参数是线程 该方法简单来说就是缓存Observable中发出的新元素, 当元素达到某个数量, 或者经过了特定的时间, 他就会将这个元素集合发送出来 let subject = PublishSubject<String>() sub

RxJava源码解析

原文链接:https://blog.csdn.net/sted_zxz/article/details/82317400 转自:https://blog.csdn.net/sted_zxz/article/details/82317400 本文基于RxJava2.2.1版本分析。 简介 官方介绍: RxJava is a Java VM implementation of Reactive Extensions: a li

RxJava 的基本使用

概述 RxJava 就是一个实现异步操作的库。它可以代替我们的 Handler,AsynTask。 简介 RxJava 最核心的两个东西是 Observables(被观察者,事件源)和 Subscribers(观察者)。  Observables 发出一系列事件,Subscribers 处理这些事件。  一个 Observable 可以发出零个或者多个事件,知道结束

【转载】RxJava2.0——从放弃到入门

转自:https://www.jianshu.com/p/cd3557b1a474 RxJava2.0——从放弃到入门 <!-- 作者区域 --> <div class="author"> <a class="avatar" href="/u/5fd2523645da"> <img src="//upload.jianshu.io/users/upl