为IObservable实现自己的运算符(详解)
作者：jingxian 发布时间：2022-04-02 08:58:15
标签：实现,运算符,iobservable
您可以通过为LINQ库不提供的操作添加新运算符，或者通过创建自己的标准查询运算符实现来提高可读性和性能，从而扩展Rx。 编写自定义版本的标准LINQ操作符在您希望使用内存中对象操作时以及当预期自定义不需要查询的全面视图时非常有用。
创建新操作符
LINQ提供了一整套操作符，涵盖了一组实体上的大多数可能的操作。 但是，您可能需要一个运算符为查询添加特定的语义，尤其是如果您可以在代码中多次重复使用该运算符。
许多现有的LINQ运算符实际上是使用其他基本LINQ运算符构建的。 例如，SelectMany运算符是通过组合Select和Merge运算符构建的，如下面的代码所示。
public static IObservable<TResult> SelectMany<TSource, TResult>( this IObservable<TSource> source, Func<TSource, IObservable<TResult>> selector)
{
return source.Select(selector).Merge();
}
In t
通过在构建新的LINQ运算符时重用现有的LINQ运算符，您可以利用Rx库中实现的现有性能或异常处理功能。
当编写自定义运算符时，最好不要留下任何未使用的一次 * ; 否则，您可能会发现资源实际上可能泄漏，取消可能无法正常工作。
定制现有运算符
向LINQ中添加新的运算符是扩展其功能的一种方法。 但是，您还可以通过将现有运算符包含到更专门和更有意义的运算符中来提高代码可读性。
0
投稿猜你喜欢
- 一. 为什么要使用接口假如有一个需求：要求实现防盗门的功能。门有"开"和"关"的功能，锁有"
本文实例讲述了Java Web项目部署在Tomcat运行出错与解决方法。分享给大家供大家参考，具体如下：1、在部署Java Web项目的过程- 前言通过此篇文章，你将了解到：Flutter windows和Android桌面应用屏幕适配的解决方案；屏幕适配的相关知识和原理；flutt
- 本文实例讲述了C#中异步回调函数用法。分享给大家供大家参考。具体如下：static void Main(string[] args){ Fu
- 题目要求思路一：模拟迭代依次判断每个节点是否合法：左子树判断是否>low，合法就向左下走，不合法往右下；右子树判断是否<high
- 以下通过3个知识点给大家讲解了上拉加载和下拉刷新的Fragment实现的方法，在对每个知识点介绍了一下用法。1.效果预览1.1.这个首页就是
- Person实体类package com.ljq.domain;public class Person {
- 1.背景 SpringBoot项目中，之前都是在controller方法的第一行手动打印 log，return之前再
- 先看看效果图：源码下载：Android Navigation TabBar控件实现多彩标签栏代码：MainActivity.javapack
- 最近在学习JavaWeb时，有用到鼠标移动事件，所以今天在这里记录一个相关的案例，同时也是对相关知识的一个巩固，效果为在鼠标移动到表格对应行
- 测试类中的问题和解决思路问题在测试类中，每个测试方法都有以下两行代码：ApplicationContext ac = new ClassPa
- 本文实例为大家分享了Unity苹果手机Taptic震动的具体代码，供大家参考，具体内容如下文件：ios震动.zip将上方文件解压之后将Mul
- 主题 ActiveMQ Spring Boot 小程序开发1.引入依赖<parent><groupId>org.sp
- springboot http转https一、安全证书的生成可以使用jdk自带的证书生成工具，jdk自带一个叫keytool的证书管理工具，
- 阅读提示 具有mybatis基础，熟练使用mybatis-plus。概述 我们都知道，mybatis-plus是一个mybatis的增强
- 上一篇我们详解了setttings.xml的配置项，里面的配置项基本都和仓库有关系，我们使用maven更多的也是要从仓库下载jar包，然后也
- 我们经常在项目中使用的线程池，但是是否关心过线程池的关闭呢，可能很多时候直接再项目中直接创建线程池让它一直运行当任务执行结束不在需要了也不去
- 前言Kotlin 的泛型与 Java 一样，都是一种语法糖，只在源代码里出现，编译时会进行简单的字符串替换。泛型是静态类型语言中不可缺少的一
- 工程搭建1.File->new->project；2.选择“Spring Initializr”，点击next；（jdk1.8默
- 一、简介1、DES 简介DES 全称为 Data Encryption Standard，即数据加密标准，是一种使用密钥加密的块算法，197
