文档建议反馈控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

《Kotlin 反应式编程》使用 RxKotlin 实现一个极简的 http DSL （ Reactive Programming Using Rx Kotlin ）《Kotlin 反应式编程》使用

/RxKotlin RxKotlin： RxJava bindings for Kotlin 使用 RxKotlin 实现一个极简的 http DSL （ Reactive Programming Using...OkHttp 是一个成熟且强大的网络库，在Android源码中已经使用OkHttp替代原先的HttpURLConnection。...提示： 更多关于OkHttp 的使用可参考: http://square.github.io/okhttp/ 创建 Kotlin Gradle 项目 我们首先使用 IDEA 创建 Kotlin Gradle...一个语言列表如下所示： Rx 支持的编程语言 项目主页 Java RxJava ： https://github.com/ReactiveX/RxJava JavaScript RxJS：https:/...使用 RxKotlin 完成请求响应的异步处理 我们首先新建一个数据发射源：一个可观察对象(Observable)，作为发射数据用 val sender = Observable.create<

1.8K20
    • 您找到你想要的搜索结果了吗？
    是的
    没有找到

    第10章 使用 Kotlin 创建 DSL第10章 使用 Kotlin 创建 DSL

    提示： 更多关于OkHttp 的使用可参考: http://square.github.io/okhttp/ 我们首先使用 IDEA 创建 Kotlin Gradle 项目 ?...一个语言列表如下所示： Rx 支持的编程语言 项目主页 Java RxJava ： https://github.com/ReactiveX/RxJava JavaScript RxJS：https:/...Rx 比较流行的库有RxJava/RxJS/Rx.NET等，当然未来RxKotlin也必将更加流行。 提示： Rx 的社区网站是： http://reactivex.io/ 。...使用 RxKotlin 完成请求响应的异步处理 我们首先新建一个数据发射源：一个可观察对象(Observable)，作为发射数据用 val sender = Observable.create的观察者，在未来某个时刻响应 sender 的通知，而不需要阻塞等待 sender 发射数据。这个很像协程中的通道编程模型。

    1.3K20

    【RxJava】ReactiveX 简介 ( ReactiveX 概念 | ReactiveX 组成部分 - 被观察者 观察者 操作符 调度器 订阅 | ReactiveX 支持语言 )

    一、RxJava 简介 1、ReactiveX 概念 RxJava 框架 是 ReactiveX ( Reactive Extensions 响应式编程扩展 ) 在 Java 语言 上的实现 , 该框架...ReactiveX 基于 数据流 的 响应式编程， 使用 函数式编程风格 和 链式调用 处理数据流， 不需要处理 线程 / 回调 / 状态管理 等复杂问题 , 提供了一种 更简单、更灵活 的 编程范式。...可以 应用于多种编程语言，如 Java、JavaScript、Swift、Kotlin 等，可以在 不同的平台 / 语言 中 使用 异步编程模型 和 操作符。...RxJava - Java 语言 RxSwift - Swift 语言 RxKotlin - Kotlin 语言 RxJS - JavaScript 语言 开发者 可以 在 不同的平台 / 不同语言 中...使用 异步编程模型 和 操作符，提高了代码 的 可复用性 和 可维护性 ;

    96410

    《Kotin 极简教程》第14章 使用 Kotlin DSL第14章 使用 Kotlin DSL《Kotlin极简教程》正式上架：

    在Kotlin 中创建 DSL ， 一般主要使用下面两个特性： 扩展函数、扩展属性 带接收者的 Lambda 表达式（高阶函数） 例如上面的示例的 UI {...}...提示： 更多关于OkHttp 的使用可参考: http://square.github.io/okhttp/ 创建 Kotlin Gradle 项目 我们首先使用 IDEA 创建 Kotlin Gradle...一个语言列表如下所示： Rx 支持的编程语言 项目主页 Java RxJava ： https://github.com/ReactiveX/RxJava JavaScript RxJS：https:/...Rx 比较流行的库有RxJava/RxJS/Rx.NET等，当然未来RxKotlin也必将更加流行。 提示： Rx 的社区网站是： http://reactivex.io/ 。...使用 RxKotlin 完成请求响应的异步处理 我们首先新建一个数据发射源：一个可观察对象(Observable)，作为发射数据用 val sender = Observable.create<

    2.1K10

    响应式编程|Kotlin与LiveData扩展函数实践技巧

    其实就算是长期接触Java的Android开发者，应该也接触过Rx系列组件，例如RxJava, RxSwift, RxKotlin等等，这些都是典型的基于响应式编程设计的组件。...3.2 RxJava能简化工作，但我们还想做的更好 上面的例子展示了一个最基础的语言层面上，构建一个响应式关系的例子。...如果我们基于响应式编程的思想去开发这个程序，比如使用RxJava，继续完善这个例子： 构建一个关系“服务器返回的数据*2，再显示到界面上”： ?...在我们重构过程中，大量使用了LiveData Extensions，极大地减少了代码量，提升了我们的工作效率。...另外，我们更主张使用多个LiveData联合触发而非特别长的链式表达，如果确实需要特别长的链式表达，尤其是需要反复切换线程的情况，我们建议使用RxJava。

    1.7K10

    反应式编程详解

    反应式宣言是一份构建现代云扩展架构的参考方案框架。这个框架主要使用消息驱动的方法来构建系统，在形式上可以达到弹性和回弹性，最后可以产生即时响应性的价值。如图 4 所示： ?...[ 图10 ] 图片来源： https://github.com/ReactiveX/RxJava/wiki/How-To-Use-RxJava 对比命令式编程和反应式编程，区别如下： 命令式编程，重视控制...publish 将一个普通的 Observable 转换为可连接的，可连接的Observable 和普通的Observable差不多，不过它并不会在被订阅时开始发射数据，而是直到使用了 Connect...比如我们这里需要有多个观察者订阅的时候。 3.2 从网络地址中获取数据 需求描述： 获取新浪的美股接口数据，并打印出股票名和价格 代码如下： ?...3.3 从数据库获取数据 需求描述： 从MySQL数据库中读取用户信息并打印出来 代码如下： ? 3.4 文章信息关联作者名称 需求描述： 将文章信息列表关联作者名称 代码如下： ?

    2.9K30

    Java 设计模式最佳实践：六、让我们开始反应式吧

    根据这个页面的说法，一个没有回应的网站在搜索引擎中的排名很低： “响应式设计是谷歌的推荐设计模式” 反应式系统是一种使用元素构成复杂系统的架构风格，有些元素是用反应式编程技术构建的。...RxJava 简介 RxJava 是从 Microsoft.NET 世界移植的反应式扩展（一个库，用于使用可观察序列编写异步和基于事件的程序）的实现。...在下面的部分中，我们将学习它的功能以及如何使用它。 可观察对象、可流动对象、观察者和订阅者 在 ReactiveX 中，观察者订阅一个可观察的对象。...它们被称为“可连接的”可观察对象，RxJava 拥有能够创建此类可观察对象的操作符。 RxJava2.0 引入了一种新的可观察类型，称为Flowable。...，将两个可观察对象发出的项目加入到组中 下面的示例使用join组合两个可观察对象，一个每 100 毫秒触发一次，另一个每 160 毫秒触发一次，并每 55 毫秒从第一个值中获取一个值，每 85 毫秒从第二个值中获取一个值

    1.8K20

    RxJava的一些入门学习分享

    现在就把目前对RxJava的一些理解和粗浅的分析做一下分享，欢迎大家拍砖。 1.什么是RxJava 要了解什么是RxJava，先需要了解一下它的理念来源：ReactiveX。...for the Java VM”，即“Java虚拟机上的使用可观测序列进行可组合可异步的基于事件的编程的库”。...，变换的详情可以从链式调用的顺序得知，因此整体代码显得特别的简洁易读和容易拓展，使用这套框架开发能够有效节省阅读代码带来的精力和时间成本。...RxJava除了使用观察者模式之外，同时也应用并拓展了迭代器模式，对数据序列是迭代遍历依次处理的，而Subscriber的onNext方法正对应Java的Iterable中的next方法。...线程切换就是这样使用这两个方法很简单的实现了。 以上就是本人入门RxJava的一些较为粗浅的学习分享，志在先做一个简单的科普，如果深入研究就会发现RxJava还有不少强大的功能。

    1.2K110

    使用Kotlin高效地开发Android App(四）总结

    使用operator修饰符来修饰特定函数名的函数，这些函数可以是成员函数也可以是扩展函数。 例如，在RxKotlin的disposable.kt中有这样一个方法。...简化的lambda表达式 在使用Kotlin高效地开发Android App(一）中，曾经介绍过尾随闭包，它可以算是一种简化的lambda表达式。...RxJava 和 LiveData、Lifecycle LiveData和Lifecycle是Google在2017年新出的Android Architecture Components的中的一部分。...例如在LoginViewModel中，login()函数大致可能是这样写的，替换了之前使用的RxLifecycle。当然，使用RxLifecycle的作用也是为了避免内存泄露。...由于在我们的App架构中已经使用了Android Architecture Components，所以可以考虑替换RxLifecycle。

    1K30

    初识RxJava 2 for Android

    为了知其然，知其所以然，下面从入门开始对最受欢迎的响应式框架RxJava进行研究。...在本系列文章最后你将会掌握所有 **RxJava 2 **的要素，然后你就可以开始编写高度响应式的App，可以处理各种同步和异步数据。所有这些更加简洁和可管理的代码都能使用Java实现。...RxJava 简化了处理数据和事件所需的代码，方法是允许开发者描述想实现的内容，而不是写一份指令列表。...通常无论何时都需要把一些后台任务的结果从发送到UI中，必须创建一个专用的Handler。 再者，RxJava 有一个更直接的解决方案。...四、RxJava的组成 目前为止，我们只是在很高的层次上看过 RxJava 。是时候具体并深入了解在 RxJava 工作期间再次出现的两个最重要的组件：Observer 和 Observable 。

    1.1K60

    改造 Android 官方架构组件 ViewModel

    , 在 Activity 执行 onDestroy 时需要释放一些对象的资源, 也可以使用到生命周期组件 LiveData LiveData 具有两个功能, 第一个功能是观察者模式, 在 Value 发生变化时通知之前注册的所有观察者...Activity 重建时存活下来, 重建后数据可继续使用, 第二个功能可以帮助开发者轻易实现 Fragment 与 Fragment 之间, Activity 与 Fragment 之间的通讯以及共享数据...从官方文档可以看出 Google 对此的建议就是 RxJava, Agera, LiveData 等类似功能的库, 你只使用一个即可 选择 RxJava 还是 LiveData ?...于是我认真的研究了其源码, LiveData 具有两个功能, 通知观察者更新数据和根据生命周期停止和恢复之前的事件, 而 Rxjava 加上 RxLifecycle, RxJava 加上 AutoDispose...指明当前 ViewModel 的构建方式, ViewModel 组件 会在合适的时机, 主动去根据 Factory 构建 ViewModel 实例, 并放入 Map 中 这时整个构建过程都被 ViewModel

    77310

    RxJava && Agera 从源码简要分析基本调用流程(1)

    同样有很多同学已经开始在自己的项目中使用RxJava。...它能够帮助我们在处理异步事件时能够省去那些复杂而繁琐的代码，尤其是当某些场景逻辑中回调中嵌入回调时，使用RxJava依旧能够让我们的代码保持极高的可读性与简洁性。...（本文基于RxJava-1.1.3） 一.用法 首先来看一个简单的例子: [image.jpg] 运行结果为： [image.jpg] 从结果中我们不难看出整体的调用流程： 首先通过调用Observable.create...接口，当这个Subscriber取消订阅的时候会将持有事件列表中的所有Subscription取消订阅，并且从此不再接受任何订阅事件。...下篇将继续从"线程切换过程"开始分析 文章来源公众号：QQ空间终端开发团队（qzonemobiledev） 相关推荐 下一篇：RxJava && Agera 从源码简要分析基本调用流程(2)

    9.2K10

    Java 设计模式最佳实践：6~9

    RxJava 简介 安装 RxJava 可观察对象、可流动对象、观察者和订阅 创建可观察对象 变换可观察对象 过滤可观察对象 组合可观察对象 错误处理 调度者 主题 示例项目 什么是反应式编程？...RxJava 简介 RxJava 是从 Microsoft.NET 世界移植的反应式扩展（一个库，用于使用可观察序列编写异步和基于事件的程序）的实现。...在下面的部分中，我们将学习它的功能以及如何使用它。 可观察对象、可流动对象、观察者和订阅者 在 ReactiveX 中，观察者订阅一个可观察的对象。...它们被称为“可连接的”可观察对象，RxJava 拥有能够创建此类可观察对象的操作符。 RxJava2.0 引入了一种新的可观察类型，称为Flowable。...，将两个可观察对象发出的项目加入到组中 下面的示例使用join组合两个可观察对象，一个每 100 毫秒触发一次，另一个每 160 毫秒触发一次，并每 55 毫秒从第一个值中获取一个值，每 85 毫秒从第二个值中获取一个值

    1.7K10

    LiveData beyond the ViewModel

    它是一个简单的观察者，能够意识到观察者的生命周期。从你的数据源或存储库中暴露LiveData是使你的架构更具反应性的一个简单方法，但也有一些潜在的陷阱。...这篇博文将帮助你避免陷阱，并使用一些模式来帮助你使用LiveData构建一个更加「反应式」的架构。...img 使用MediatorLiveData来组合数据的方法是在不同的方法中添加来源和设置值。...请记住，LiveData会将最新的值分派给新的观察者。另外，Lollipop中引入了Activity转换，它们带来了一个有趣的边缘情况：两个Activity处于活动状态。...在ViewModel中，我们需要公开一个randomNumber属性，从生成器中获取数字。为此使用MediatorLiveData并不理想，因为它要求你在每次需要新数字时都要添加源。

    1.5K30

    Rxjava源码解析笔记 | 创建Observable 与 ObserverSubscriber 以及之间订阅实现的源码分析

    简单回顾 如果抛开Rxjava的操作符以及其线程控制的话，Rxjava的最基本使用是比较简单的 第一步，创建被观察者Observable； 第二步，创建观察者Observer/Subscriber...， 被观察者用来通知观察者的notifyObservers()方法； Subscriber（观察者） 一个核心方法 subscribe() 订阅方法， 完成观察者和被观察者之间的订阅； Rxjava...； 这里有两个接口——Observer和Subscriber 其实Subscriber内部也只对Observer做了一些拓展， 它们两个的使用方式基本是相同的； 当然就是有一些回调接口的差异；...； 当“订阅事件的列表” （也即当前观察者中的一个放着所有订阅事件的列表的成员变量） 之中不再有订阅事件时， 调用这个方法来对“订阅事件列表”进行解绑； isUnsubscribed()：判断是否已经解绑订阅事件...最基本的使用方式； Rxjava的SDK中subscribe()的传入参数 是Subscriber时候（observable.subscribe(subscriber);）的源码： public

    1.6K30

    RxJava2.X 源码分析（四）：观察者线程切换原理

    作者博客 http://www.cherylgood.cn 前言 基于RxJava2.1.1 我们在前面的 RxJava2.0使用详解（一）初步分析了RxJava从创建到执行的流程。...RxJava2.0使用详解（二) 中分析了RxJava的随意终止Reactive流的能力的来源；也明白了RxJava的onComplete();与onError(t);只有一个会被执行的秘密。...RxJava2.X 源码分析（三）中探索了RxJava2调用subscribeOn切换被观察者线程的原理。...继续实现我们在第一篇中定下的小目标 从Demo到原理 OK，我们的Demo还是上次的demo，忘记了的小伙伴可以点击RxJava2.X 源码分析（三），这里就不再重复了哦，我们直接进入正题。...我们继续往下看，我猜套路跟subscribeOn的逃不多，也是采用装饰者模式，wrapper我们的Observable和Observer产生一个中间被观察者和观察中，通过中间被观察者订阅上游被观察者，通过中间观察者接收上游被观察者下发的数据

    63930

    RxJava2.X 源码解析（二) ：神秘的取消订阅流程

    作者博客 http://www.cherylgood.cn/ 前言 基于RxJava2.1.1 我们在前一篇# RxJava2.0源码解析（一）初步分析了RxJava从创建到执行的流程。...本篇我们将探索RxJava2.x提供给我们的Disposable能力的来源。 要相信，任何神奇的功能，当你探索了其本质之后，收获都是巨大的。 从Demo到原理 ? (￣∇￣)猜猜会输出什么呢？ ?...从结果我们还发现，后面的Reactive流被终止了，也就是订阅者或者观察者收不到后面的信息了，但是生产者或者说被订阅者、被观察者的代码还是会继续执行的。 Ok，我们从哪开始入手呢？...RxJava的onComplete();与onError(t);只有一个会被执行的秘密原来是它？ 再看另外两个方法的调用 ? 其内部也基本做了同样的操作，先判断!...更详细的分析放入了代码中 总结 通过本次，1、我们了解了RxJava的随意终止Reactive流的能力的来源；2、过程中也明白了RxJava的onComplete();与onError(t);只有一个会被执行的秘密

    79520

    RxJava系列二(基本概念及使用介绍)

    前言 上一篇的示例代码中大家一定发现了Observable这个类。从纯Java的观点看，Observable类源自于经典的观察者模式。...观察者模式很适合下面这些场景中的任何一个： 当你的架构有两个实体类，一个依赖另一个，你想让它们互不影响或者是独立复用它们时。 当一个变化的对象通知那些与它自身变化相关联的未知数量的对象时。...RxJava如何使用 我自己在学习一种新技术的时候通常喜欢先去了解它是怎么用的，掌握了使用方法后再去深挖其原理。那么我们现在就来说说RxJava到底该怎么用。...ps:onNext就相当于普通观察者模式中的update RxJava中添加了普通观察者模式缺失的三个功能： RxJava中规定当不再有新的事件发出时，可以调用onCompleted()方法作为标示；...OnSubscribe的call()方法中的参数Subscriber怎么就变成了subscribe()方法中的观察者Observer？！！！这俩儿货明明看起来就是两个不同的类啊。

    972100
    点击加载更多

    扫码

    添加站长 进交流群

    领取专属 10元无门槛券

    手把手带您无忧上云

    扫码加入开发者社群

    相关资讯

    热门标签

    更多标签

    活动推荐

      运营活动

      活动名称
      广告关闭

      腾讯云开发者

      扫码关注腾讯云开发者

      扫码关注腾讯云开发者

      领取腾讯云代金券

      热门产品

      热门推荐

      更多推荐

      Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有

      深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

      腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287

      领券