搜索结果
查询Tags标签： subscribe，共有 15条记录-
SAP 电商云 Spartacus UI ActiveCartService 的 isStable API 里的 debounce 和 timer 操作符
这个 isStable API 的实现是 switchMap 和 debounce，[timer](https://www.learnrxjs.io/learn-rxjs/operators/creation/timer) 等操作符的组合。首先看 timer 的例子： // RxJS v6+ import { timer } from rxjs;//emit 0 after 1 second then complete, since no second…
2022/4/15 23:42:37 人评论 次浏览 -
Redis的发布订阅
第一步先启动Redis的一个线程redis-cli 用来启动Redis执行 publish channe1.1 123456 //1.1是管道的名称 //123456是发布的内容 返回表示订阅号的数量。 订阅： 执行//单次订阅 subscribe channe1.1 //1.1 管道号//多次订阅 subscribe channe1.1 channe1.0//返回 //…
2022/4/9 2:20:32 人评论 次浏览 -
RabbitMQ--Publish/Subscribe
Publish/Subscribe 交换机的类型直连交换机--direct exchange 直连交换机是一种带路由功能的交换机，一个队列会和一个交换机绑定，除此之外再绑定一个routing_key，当消息被发送的时候，需要指定一个binding_key，这个消息被送达交换机的时候，就会被这个交换机送到指定的…
2022/1/31 6:04:19 人评论 次浏览 -
Sqoop 从hive中使用export导出到mysql中，出现乱码问题
如图所示解决方案： Mysql建库时，设置编码方式为utf8。 create database if not exists test DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;character set 是字符集 collate 设置排序规则。 预防万一，建表也设置成utf8 CREATE TABLE IF NOT EXISTS t_order_subs…
2021/12/24 2:07:03 人评论 次浏览 -
Sqoop 从hive中使用export导出到mysql中，出现乱码问题
如图所示解决方案： Mysql建库时，设置编码方式为utf8。 create database if not exists test DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;character set 是字符集 collate 设置排序规则。 预防万一，建表也设置成utf8 CREATE TABLE IF NOT EXISTS t_order_subs…
2021/12/24 2:07:03 人评论 次浏览 -
.Net中的反应式编程(Reactive Programming)
一、反应式编程(Reactive Programming) 1、什么是反应式编程：反应式编程(Reactive programming)简称Rx，他是一个使用LINQ风格编写基于观察者模式的异步编程模型。简单点说Rx = Observables + LINQ + Schedulers。 2、为什么会产生这种风格的编程模型？我在本系列文章开始…
2021/12/12 17:21:36 人评论 次浏览 -
.Net中的反应式编程(Reactive Programming)
一、反应式编程(Reactive Programming) 1、什么是反应式编程：反应式编程(Reactive programming)简称Rx，他是一个使用LINQ风格编写基于观察者模式的异步编程模型。简单点说Rx = Observables + LINQ + Schedulers。 2、为什么会产生这种风格的编程模型？我在本系列文章开始…
2021/12/12 17:21:36 人评论 次浏览 -
Redis 笔记（五）消息订阅与发布
Redis 发布订阅 (pub/sub) 是一种消息通信模式：发送者 (pub) 发送消息，订阅者 (sub) 接收消息。客户端可以订阅任意数量的频道。 注意：目前 Redis 的消息与订阅在实际开发中基本不会使用，如果要用到消息中间件，推荐 ActiveMQ、RabbitMQ1、subscribe：订阅一个或者多个…
2021/11/2 19:13:16 人评论 次浏览 -
Redis 笔记（五）消息订阅与发布
Redis 发布订阅 (pub/sub) 是一种消息通信模式：发送者 (pub) 发送消息，订阅者 (sub) 接收消息。客户端可以订阅任意数量的频道。 注意：目前 Redis 的消息与订阅在实际开发中基本不会使用，如果要用到消息中间件，推荐 ActiveMQ、RabbitMQ1、subscribe：订阅一个或者多个…
2021/11/2 19:13:16 人评论 次浏览 -
Warning: Subscription For Node Down Event Still Pending
Warning: Subscription For Node Down Event Still Pending In Listener Log (Doc ID 372959.1)Oracle Net Services - Version 10.2.0.1 to 11.2.0.4 [Release 10.2 to 11.2]Information in this document applies to any platform.***Checked for relevance on 29-JAN-2…
2021/9/17 9:04:49 人评论 次浏览 -
Warning: Subscription For Node Down Event Still Pending
Warning: Subscription For Node Down Event Still Pending In Listener Log (Doc ID 372959.1)Oracle Net Services - Version 10.2.0.1 to 11.2.0.4 [Release 10.2 to 11.2]Information in this document applies to any platform.***Checked for relevance on 29-JAN-2…
2021/9/17 9:04:49 人评论 次浏览 -
RxRouter -- 一个轻量级、简单、智能并且强大的安卓路由库，彻底帮你搞懂
override fun onCreate() {super.onCreate()RxRouterProviders.add(MainRouterProvider()) }}最后，就可以开始我们的表演了：RxRouter.of(context) .route(“this is a uri”) .subscribe()### 参数传递携带参数跳转：通过with方法，你可以给本次路由添加一系列参数.RxRo…
2021/9/6 23:40:19 人评论 次浏览 -
RxRouter -- 一个轻量级、简单、智能并且强大的安卓路由库，彻底帮你搞懂
override fun onCreate() {super.onCreate()RxRouterProviders.add(MainRouterProvider()) }}最后，就可以开始我们的表演了：RxRouter.of(context) .route(“this is a uri”) .subscribe()### 参数传递携带参数跳转：通过with方法，你可以给本次路由添加一系列参数.RxRo…
2021/9/6 23:40:19 人评论 次浏览 -
Rxjava创造操作符
rxjava 操作符kotlin 语法练习 参考 ：https://github.com/ReactiveX/RxJava/ 依赖implementation io.reactivex.rxjava2:rxandroid:2.0.2implementation io.reactivex.rxjava2:rxjava:2.2.9 经常会使用的固定式语句 1、异步订阅观察者 （切换到子线程）.subscribeOn(Sche…
2021/6/29 14:21:38 人评论 次浏览 -
rxjs 的 observable 是什么？
原文链接: https://segmentfault.com/a/1190000009924164RxJS 是响应式编程 (reactive programming) 强大的工具，今天我们将深入介绍 Observables 和 Observers 的内容，以及介绍如何创建自己的操作符 (operators)。如果你之前已经使用过 RxJS，并希望了解 Observable 及…
2021/4/15 10:25:10 人评论 次浏览
