subscriber

首页 > TAG信息列表 > subscriber

EventBus 源码解析及使用体验，自己动手实现OkHttp

首先： EventBus.getDefault()其实就是个单例，和我们传统的getInstance一个意思： /* Convenience singleton for apps using a process-wide EventBus instance. / public static EventBus getDefault() { if (defaultInstance == null) { synchronized (EventBus.class) { if

MQTT服务搭建和简单使用

本文通过MetaWeblog自动发布，原文及更新链接：https://extendswind.top/posts/technical/mqtt_simple_use MQTT为了物联网的消息传递而设计，业余时间弄了个报警器，之前用长轮询的实现感觉略麻烦，测试了一下MQTT的实现。个人感觉使用比较简单，对网络问题的处理也比较完善，但是某些方面的灵

C# 委托事件，发布者订阅者模式简单的demo

public class Publisher { public void Print() { Console.WriteLine("来活了"); } } class Subscriber { public delegate void NumManipulationHandler(); public event NumManipulati

Couldn‘t find executable named person_subscriber below /home/yue/catkin_ws/src/... 找不到可执行文件的原因

跟着古月老师在做ROS的时候，发现报错如下：不能找到可执行文件 ~$ rosrun learning_topic person_subscriber [rosrun] Couldn't find executable named person_subscriber below /home/yue/catkin_ws/src/learning_topic 在网上找了原因，

熔断器 Hystrix 的原理与使用

前言将单体应用迁移到分布式框架后，很大可能会遇到这样的问题：系统仅有一个控制单元，它会调用多个运算单元，如果某一个运算单元（作为服务提供者）不可用，将导致控制单元（作为服务调用者）被阻塞，最终导致控制单元崩溃，进而导致整个系统都面临着瘫痪的风险。服务雪崩效应形成的原

vue-尤雨溪讲课系列二

dependence tracking 实现依赖跟踪？？这是什么意思？？举个例子： a = 10; b= a*3 要求当a改变了b同时跟着改变， b依赖于a 这就是依赖跟踪。 a是被依赖项。要求： Create a Dep class with two methods: depend and notify.Create an autorun function that takes an updater functio

第二章 Publisher 和 Subscriber （Part. 1）

Publiser 简介 Combine 的核心是发布者协议。该协议定义了一种类型的要求，以便能够随时间向一个或多个订阅者传输一系列值。换句话说，你可以将感兴趣的值，用发布者将其用事件的方式发布出去。发布者可以发出零个或多个值，但只能发出一个完成事件，可以是正常的完成事件，也可以是错误

ros publish and subscribe

回调关系建立创建handle时，会listen一个tcp端口 bool TransportTCP::listen(int port, int backlog, const AcceptCallback& accept_cb) bool TransportTCP::initializeSocket() 设置poll的回调 poll_set_->addSocket(sock_, boost::bind(&TransportTCP::socketUpdate, this, _1),

EventBus

EventBus配置 android { defaultConfig { javaCompileOptions { annotationProcessorOptions { // 生成的Index类的名称 arguments = [ eventBusIndex : 'com.example.myapp.MyEventBusIndex' ] }

Qt - QMQTT订阅者和发布者

简介使用Qt官方提供的QMQTT源代码编译为QMQTT模块，来编写简单的订阅者和发布者。订阅者 1 #ifndef SUBSCRIBER_H 2 #define SUBSCRIBER_H 3 4 #include <QObject> 5 6 #include <QDebug> 7 #include <qmqtt.h> 8 #include <QTimer> 9 10 11 //订阅 12 class Sub

guava EventBus源码阅读

post → @Subscribe 方法流程 1.post 调用EventBus this.dispatcher.dispatch(event, eventSubscribers); 2.dispatcher = Dispatcher.perThreadDispatchQueue() 3. new Dispatcher.PerThreadQueuedDispatcher() = new PerThreadQueuedDispatcher(queue,dispatching) 4. PerThrea

05、Android--EventBus原理解析

EventBus原理 EventBus构造方法当我们要使用EventBus时，首先会调用EventBus.getDefault（）来获取EventBus实例。 public static EventBus getDefault() { if (defaultInstance == null) { synchronized (EventBus.class) { if (defaultInstance == null) {

OpenDDS 在两台机器上实现通讯

OpenDDS 在两台机器上实现通讯通过Ip和Port通信在A机器上运行DCPSInfoRepo程序修改subscriber和publisher的配置文件sub.ini 和 pub.ini在A机器上运行subscriber在B机器上运行publisher小Tips 通过Ip和Port通信打开命令行切换到上一节创建的测试文件夹目录下在A机器

一、响应式编程的产生_Reactive Streams组件使用、源码理解

1.响应式编程的产生背景：为了解决异步编程过程中出现的种种难题，人们提出了各种各样方法来规避这些问题，这些方法称为响应式编程(Reactive Programming)，就像面向对象编程、函数式编程一样，响应式编程也是另一种编程范式。响应式编程，本质上是对数据流或某种变化所作出的反应，但是这

RACSignal的Subscription深入分析

ReactiveCocoa是一个FRP的思想在Objective-C中的实现框架，目前在美团的项目中被广泛使用。对于ReactiveCocoa的基本用法，网上有很多相关的资料，本文不再讨论。RACSignal是ReactiveCocoa中一个非常重要的概念，而本文主要关注RACSignal的实现原理。在阅读之前，你需要基本掌握RACSignal的

细说ReactiveCocoa的冷信号与热信号（一）

背景 ReactiveCocoa（简称RAC）是最初由GitHub团队开发的一套基于Cocoa的FRP框架。FRP即Functional Reactive Programming（函数式响应式编程），其优点是用随时间改变的函数表示用户输入，这样就不需要可变状态了。我们之前的文章“RACSignal的Subscription深入分析”里曾经详细讲解过RAC核

细说ReactiveCocoa的冷信号与热信号（三）：怎么处理冷信号与热信号

第一篇文章中我们介绍了冷信号与热信号的概念，前一篇文章我们也讨论了为什么要区分冷信号与热信号，下面我会先为大家揭晓热信号的本质，再给出冷信号转换成热信号的方法。揭示热信号的本质在ReactiveCocoa中，究竟什么才是热信号呢？冷信号是比较常见的，map一下就会得到一个冷信号。但在

ROS中的消息通信机制

打个比方，我们通常在网上视频学习的时候，通常先去搜索我们要学习的内容，然后逐个筛选并找到想要的视频。而发布视频的作者首先要在网络上创建账户，通过网络发布视频，也可以通过网络学习其他人的视频，我们通过他的账户，可以告诉他我们接下来想学习的视频并期望他能够接下来发出这

Reactive Spring实战 -- 理解Reactor的设计与实现

转： Reactive Spring实战 -- 理解Reactor的设计与实现 Reactor是Spring提供的非阻塞式响应式编程框架，实现了Reactive Streams规范。它提供了可组合的异步序列API，例如Flux（用于[N]个元素）和Mono（用于[0 | 1]个元素）。 Reactor Netty项目还支持非阻塞式网络通信，非常适用于微服务架构，为HT

从ngrx store里selector出来的Observable，执行subscribe的单步调试

源代码： getNextPageContext(): Observable<PageContext> { const a = this.store.pipe(select(RoutingSelector.getNextPageContext)); console.log('Jerry next page context: ' + a); a.subscribe((b) =>{ console.log(b); });

guava eventbus 原理+源码分析

前言: guava提供的eventbus可以很方便的处理一对多的事件问题，最近正好使用到了,做个小结,使用的demo网上已经很多了,不再赘述,本文主要是源码分析+使用注意点+新老版本eventbus实现方式对比一.原理将定义的hander注册到eventbus中，eventbus遍历该handler及其父类中含有@s

ROS入门三话题中的发布者Publisher和订阅者Subscriber

ROS入门三话题中的发布者Publisher和订阅者Subscriber 乌龟例程中的Publisher与Subscriber查看乌龟的节点关系乌龟发布者Publisher发布者模型图实现总结流程乌龟订阅者Subscriber发布者模型图实现总结 Publisher之“Hello World”例程创建Publisher创建Subscriber配置功

【Delphi】UEventBus

unit UEventBus; interface uses System.Classes; type IEventBus = interface(IUnknown) procedure Notify(information: TObject); end; TEventBus = class(TObject) private subscribers: TInterfaceList; public

手写简化EventBus，理解框架核心原理

JDK9新特性 Reactive Stream 响应式流

JDK9新特性 Reactive Stream 响应式流本篇主要讲解 JDK9特性 Reactive Stream 响应式流，介绍 Reactive Stream是什么背压是什么，以及JDK9中提供的关于Reactive Stream的接口和 2个使用案例包括如何使用Processor。 1.Reactive Stream 概念 Reactive Stream (响应式流