登录注册
京东自营 + 国补 iPhone 历史最低价          国家补贴 享8折

欢马劈雪

  • ElementAt

    如果我们只想要可观测序列发射的第五个元素该怎么办？elementAt()函数仅从一个序列中发射第n个元素然后就完成了。如果我们想查找第五个元素但是可观测序列只有三个元素可供发射时该怎么办？我们可以使用elementAtOrDefault()。下图展示了如何通过使用elementAt(2)从一个序列中选择第三个元素以及如何创建一个只发射指定元素的新的Observable。

    欢马劈雪
    elementat， rxjava， essentials， 中文翻译

  • Skip and SkipLast

    下图中展示了如何使用skip(2)来创建一个不发射前两个元素而是发射它后面的那些数据的序列。skip()和skipLast()函数与take()和takeLast()相对应。它们用整数N作参数，从本质上来说，它们不让Observable发射前N个或者后N个值。如果我们知道一个序列以没有太多用的“可控”元素开头或结尾时我们可以使用它。

    欢马劈雪
    skip， and， skiplast， rxjava， essentials

  • First and last

    下图展示了如何从一个从可观测源序列中创建只发射第一个元素的序列。first()方法和last()方法很容易弄明白。它们从Observable中只发射第一个元素或者最后一个元素。这两个都可以传Func1作为参数，：一个可以确定我们感兴趣的第一个或者最后一个的谓词：下图展示了last()应用在一个完成的序列上来创建一个仅仅发射最后一个元素的新的Observable。

    欢马劈雪
    first， and， last， rxjava， essentials

  • 有且仅有一次

    一个可观测序列会在出错时重复发射或者被设计成重复发射。distinct()和distinctUntilChanged()函数可以方便的让我们处理这种重复问题。Distinct如果我们想对一个指定的值仅处理一次该怎么办？我们可以对我们的序列使用distinct()函数去掉重复的。就像takeLast()一样，distinct()作用于一个完整的序列，然后得到重复的过滤项，它需要记录每一个发射的值。

    欢马劈雪
    仅有， 一次， rxjava， essentials， 中文翻译

  • 获取我们需要的数据

    当我们不需要整个序列时，而是只想取开头或结尾的几个元素，我们可以用take()或takeLast()。Take如果我们只想要一个可观测序列中的前三个元素那将会怎么样，发射它们，然后让Observable完成吗？take()函数用整数N来作为一个参数，从原始的序列中发射前N个元素，然后完成：private void loadList(List<AppInfo> apps) { mRecyclerView.setVisibility(View.

    欢马劈雪
    获取， 我们， 需要， 数据， rxjava

  • 过滤序列

    RxJava让我们使用filter()方法来过滤我们观测序列中不想要的值，在上一章中，我们在几个例子中使用了已安装的应用列表，但是我们只想展示以字母C开头的已安装的应用该怎么办呢？在这个新的例子中，我们将使用同样的列表，但是我们会过滤它，通过把合适的谓词传给filter()函数来得到我们想要的值。上一章中loadList()函数可以改成这样：private void loadList(List<

    欢马劈雪
    过滤， 序列， rxjava， essentials， 中文翻译

  • 过滤Observables

    在上一章中，我们学习了使用RxJava创建一个Android工程以及如何创建一个可观测的列表来填充RecyclerView。我们现在知道了如何从头、从列表、从一个已存在的传统Java函数来创建Observable。这一章中，我们将研究可观测序列的本质：过滤。我们将学到如何从发射的Observable中选取我们想要的值，如何获取有限个数的值，如何处理溢出的场景，以及更多的有用的技巧。

    欢马劈雪
    过滤， observables， rxjava， essentials， 中文翻译

  • 总结

    在本章中，我们创建了第一个由RxJava强化的Android应用程序。我们从头、从已有的列表、从已有的函数来创建Observable。我们也学习了如何创建重复发射的Observables，间隔发射的Observables以及延迟发射的Observables。在下一章中，我们将掌握过滤操作，能够从我们接收到的序列中创建我们需要的序列。

    欢马劈雪
    总结， rxjava， essentials， 中文翻译

  • 再多几个例子

    在这一节中，我们将基于RxJava的just(),repeat(),defer(),range(),interval(),和timer()方法展示一些例子。just()假如我们只有3个独立的AppInfo对象并且我们想把他们转化为Observable并填充到RecyclerView的item中：List<AppInfo> apps = ApplicationsList.getInstance().getList();AppInfo appOne = apps.get(0);AppInfo appTwo = apps.get(10);

    欢马劈雪
    再多， 几个， 例子， rxjava， essentials

  • 从列表创建一个Observable

    在这个例子中，我们将引入from()函数。使用这个特殊的“创建”函数，我们可以从一个列表中创建一个Observable。Observable将发射出列表中的每一个元素，我们可以通过订阅它们来对这些发出的元素做出响应。为了实现和第一个例子同样的结果，我们在每一个onNext()函数更新我们的适配器，添加元素并通知插入。我们将复用和第一个例子同样的结构。

    欢马劈雪
    列表， 创建， 一个， observable， rxjava

  • 我们的第一个Observable

    在我们的第一个列子里，我们将检索安装的应用列表并填充RecycleView的item来展示它们。我们也设想一个下拉刷新的功能和一个进度条来告知用户当前任务正在执行。首先，我们创建Observable。我们需要一个函数来检索安装的应用程序列表并把它提供给我们的观察者。我们一个接一个的发射这些应用程序数据，将它们分组到一个单独的列表中，以此来展示响应式方法的灵活性。

    欢马劈雪
    我们， 第一个， observable， rxjava， essentials

  • 工具

    出于实用，我们引入了Lombok 和 Butter Knife。这两个可以帮助我们在Android应用程序中少写许多模板类代码。LombokLombok使用注解的方式为你生成许多代码。大多数情况下我们使用其生成getter/setter、toString()、equals()、hashCode()。它来自于一个Gradle依赖和Android Studio插件。

    欢马劈雪
    工具， rxjava， essentials， 中文翻译

  • 启动引擎

    我们将使用IntelliJ IDEA/Android Studio来创建这个工程，因此你会对截图看起来比较熟悉。让我们开始创建一个新的Android工程。你可以创建你自己的工程或者用本书中提供的导入。选择你自己喜欢的创建方式这取决于你。如果你想用Android Studio创建一个新的工程，通常你可以参考官方文档：http://developer.android.

    欢马劈雪
    启动， 引擎， rxjava， essentials， 中文翻译

  • 向响应式世界问好

    在上一章中，我们对观察者模式有个理论上的快速概述。我们也看了从头开始、从列表、或者从已经存在的函数来创建Observables。在本章中，我们将用我们学到的来创建我们第一个响应式Android应用程序。首先，我们需要搭建环境，导入需要的库和有用的库。然后我们将创建一个简单的应用程序，在不同的flavors中包含几个用RxJava填充的RecycleView items。

    欢马劈雪
    响应式， 世界， 问好， rxjava， essentials

  • 总结

    本章中，我们了解到了什么是观察者模式，为什么Observables在今天的编程场景中如此重要，以及如何创建Observables和subjects。下一章中，我们将创建第一个基于RxJava的Android应用程序，学习如何检索数据来填充listview，以及探索如何创建一个基于RxJava的响应式UI。

    欢马劈雪
    总结， rxjava， essentials， 中文翻译

  • Subject = Observable + Observer

    subject是一个神奇的对象，它可以是一个Observable同时也可以是一个Observer：它作为连接这两个世界的一座桥梁。一个Subject可以订阅一个Observable，就像一个观察者，并且它可以发射新的数据，或者传递它接受到的数据，就像一个Observable。很明显，作为一个Observable，观察者们或者其它Subject都可以订阅它。一旦Subject订阅了Observable，它将会触发Observable开始发射。

    欢马劈雪
    subject， observable， observer， rxjava， essentials

  • Observable

    当我们异步执行一些复杂的事情，Java提供了传统的类，例如Thread、Future、FutureTask、CompletableFuture来处理这些问题。当复杂度提升，这些方案就会变得麻烦和难以维护。最糟糕的是，它们都不支持链式调用。RxJava Observables被设计用来解决这些问题。它们灵活，且易于使用，也可以链式调用，并且可以作用于单个结果程序上，更有甚者，也可以作用于序列上。

    欢马劈雪
    observable， rxjava， essentials， 中文翻译

  • RxJava观察者模式工具包

    在RxJava的世界里，我们有四种角色：ObservableObserverSubscriberSubjectsObservables和Subjects是两个“生产”实体，Observers和Subscribers是两个“消费”实体。

    欢马劈雪
    rxjava， 观察者模式， 工具包， essentials， 中文翻译

  • 你什么时候使用观察者模式？

    观察者模式很适合下面这些场景中的任何一个：当你的架构有两个实体类，一个依赖另一个，你想让它们互不影响或者是独立复用它们时。当一个变化的对象通知那些与它自身变化相关联的未知数量的对象时。当一个变化的对象通知那些无需推断具体是谁的对象时。

    欢马劈雪
    什么时候， 使用， 观察者模式， rxjava， essentials

  • 观察者模式

    在今天，观察者模式是出现的最常用的软件设计模式之一。它基于subject这个概念。subject是一种特殊对象，当它改变时，那些由它保存的一系列对象将会得到通知。而这一系列对象被称作Observers,它们会对外暴漏了一个通知方法,当subject状态发生变化时会调用的这个方法。在上一章中，我们看到了电子表单的例子。现在我们可以展开这个例子讲，展示一个更复杂的场景。

    欢马劈雪
    观察者模式， rxjava， essentials， 中文翻译
上一页 下一页

个人简介

  1. 欢马劈雪

  2. 纵马驰骋迎雪而行

  3. 获得 161932 积分

  4. https://nowjava.com/creator/10001

热门标签

关注时代Java

Copyright © 2014-2024NowJava. All Rights Reserved. 时代Java 版权所有 京ICP备14059627号-7

关注时代Java