- 综合排序
- 最热优先
- 最新优先
- 来自专栏Android开发经验分享
Flowable subscribe流程介绍
转载请以链接形式标明出处： 本文出自:103style的博客 Flowable 的 subscribe 方法 public final Disposable subscribe() { , FlowableInternalHelper.RequestMax.INSTANCE); } public final Disposable subscribe(Consumer<? (ls); return ls; } public final void subscribe(Subscriber<? StrictSubscriber<T>(s)); } } public final void subscribe(FlowableSubscriber<? 而 subscribe(Subscriber<?
59610编辑于 2022-12-19 - 来自专栏WordPress果酱
留言订阅插件 -- Subscribe to Comments
今天给大家介绍一下 Subscribe to Comments 这个留言订阅插件。 Subscribe to Comments 2.1 这个插件可以让你的读者在留言之前通过选择一个选择框，然后得到以后留言的 e-mail 通知。 安装 这个插件安装比较简单，大致如下： 把 subscribe-to-comments.php 上传到插件目录下 在插件管理界面激活插件 可选，如果你的WordPress主题没有 comment_form 定制化 安装好之后，在管理界面的 Options 下就会多出一个 subscribe to Comments 页面，通过这个页面你可以配置这个插件。 首先你可以输入通知邮件发送这个的姓名和邮箱。
1.1K30编辑于 2023-04-13 - 来自专栏johnhuster
mono subscribe源码分析
https://blog.csdn.net/john1337/article/details/101028908这篇文章已经对整个project reactor工作流程做了概述，本文对mono的subscribe 源码进行更细的描述： 本文将以实际代码来分析下project reactor常见的subscribe工作原理 Mono.just("hello") .filter(t- >t.startsWith("h")) .map(String::toUpperCase) .subscribe(System.out::println); 上面是一个简单的反应式编程的代码 经过过滤处理，然后经过map进行处理，熟悉jdk stream的对map这个操作一定不会陌生，map及其以前的操作仅仅是创建了一个publisher，上面仅仅是声明阶段，并没有产生实际效果，只有经过了subscribe = operator.subscribeOrReturn(subscriber); if (subscriber == null) { // null means "I will subscribe
1.1K10编辑于 2022-03-28 - 来自专栏Android开发经验分享
Observable subscribe流程介绍
Disposable subscribe() { return subscribe(Functions.emptyConsumer(), Functions.ON_ERROR_MISSING, ()); } public final Disposable subscribe(Consumer<? ()); } public final Disposable subscribe(Consumer<? (ls); return ls; } public final void subscribe(Observer<? super T> observer); subscribe() subscribe(Consumer<? super T> onNext) subscribe(Consumer<?
60310编辑于 2022-12-19 - 来自专栏腾讯云流计算 Oceanus
TDSQL-subscribe-connector最佳实践（上）
本文介绍了如何在 Oceanus 平台使用 tdsql-subscribe-connector 1 ，从 TDSQL-MySQL 订阅任务 2 创建，到 Oceanus 作业创建、最终数据验证，实现全流程的操作指导 [1-tdsql-subscribe-connector数据流程图.png] 上述流程图简要说明了使用 tdsql-subscribe-connector 时，整个数据流向情况。 TDSQL 的 binlog 数据，会通过订阅任务发送到 Kafka（这里的 Kafka 已经包含在订阅任务中，无需重新创建实例），然后 Oceanus 可以通过 tdsql-subscribe-connector 例如，以下订阅任务中，就指定了同一个库下的多张表： [2-订阅任务-多表.png] 创建 Oceanus SQL 作业 创建 SQL 作业 目前 tdsql-subscribe-connector 仅支持在 前，需要构建数据订阅任务； tdsql-subscribe-connector 目前只支持增量阶段，没有全量阶段； 当订阅任务指定了多个表时，多个表的 Schema 需要保持一致； 参考链接 1 tdsql-subscribe-connector
1.1K100编辑于 2022-05-17 - 来自专栏子晓AI量化
迅投miniqmt行情数据subscribe_whole_quote、subscribe_quote、get_full_tick怎么选
最近有同学反馈用get_full_tick频繁获取全市场数据卡死， 我当时推荐他用subscribe_whole_quote。 这里聊一聊获取行情数据subscribe_whole_quote、subscribe_quote、get_full_tick这几个的区别。 二、适用场景、优缺点 1. subscribe_whole_quote —— 全市场高效推送器 工作模式：被动推送，增量更新。 需要1分钟、5分钟K线数据 → 只能用 subscribe_quote 没有哪个函数是万能的，关键是理解它们的性格，然后组合使用。 比如，每天早上先用 get_full_tick 快速扫描选出强势板块，然后对板块内的个股用 subscribe_whole_quote 实时监控异动，最后对真正开仓的股票用 subscribe_quote
40010编辑于 2026-05-26 - 来自专栏Dabenshi
Subscribe Hacks v1.0
第二步：接下来，/engine/modules/addcomments.php文件中查找： 复制代码 if ( $config['mail_comments'] OR $config['allow_subscribe '] ) { 在上面添加： 复制代码 $guest_email = $mail; 接着查找： 复制代码 if ($config['allow_subscribe'] AND $is_logged AND $_POST['allow_subscribe'] AND $user_group[$member_id['user_group']]['allow_subscribe']) { $found_subscribe "_subscribe WHERE news_id='{$post_id}' AND user_id='{$member_id['user_id']}'" ); if( ! $found_subscribe['count'] ) { $s_hash = md5( random_bytes(32) ); $db->query( "INSERT INTO "
35430编辑于 2023-08-24 - 来自专栏10km的专栏
jedis:subscribe(订阅)断线重连(reconnect)
下面是我的应用中实现subscribe reconnect的逻辑。 如果连接异常则释放当前连接对象重新申请连接 for(;;){/** 无限循环,JVM结束时自动关闭线程 */ try{ // 获取Jedis实例执行频道订阅 getJedis().subscribe
3.8K20发布于 2019-05-25 - 来自专栏日积月累1024
phpredis subscribe超时问题及解决
问题描述 redis提供了pub/sub功能，但在使用phpredis的subscribe时发现这样一个问题，代码如下（sub.php）： <? { var_dump($msg); } $redis = new Redis(); $res = $redis->connect('127.0.0.1', '7979'); $redis->subscribe message 'read error on connection' in sub.php:11 Stack trace: #0 /search/ballqiu/sub.php(11): Redis->subscribe htons(7979), sin_addr=inet_addr("127.0.0.1")}, 16) = -1 EINPROGRESS (Operation now in progress) //发送subscribe 总结 使用phpredis的subscribe时，默认60内没有收到消息，sub端就会因超时异常退出。可以自行设置延长超时时间或永不超时。
1.7K10发布于 2020-12-07 - 来自专栏码匠的流水账
聊聊NacosNamingService的subscribe及unsubscribe
序 本文主要研究一下NacosNamingService的subscribe及unsubscribe NacosNamingService nacos-1.1.3/client/src/main/java @Override public void subscribe(String serviceName, EventListener listener) throws NacosException { subscribe(serviceName, new ArrayList<String>(), listener); } @Override public void subscribe(String serviceName, String groupName, EventListener listener) throws NacosException { { subscribe(serviceName, Constants.DEFAULT_GROUP, clusters, listener); } @Override
94430发布于 2019-10-16 - 来自专栏偏前端工程师的驿站
Architecture Pattern: Publish-subscribe Pattern
https://en.wikipedia.org/wiki/Messaging_pattern https://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern
1K100发布于 2018-01-18 - 来自专栏码匠的流水账
聊聊NacosNamingService的subscribe及unsubscribe
序 本文主要研究一下NacosNamingService的subscribe及unsubscribe timg (23).jpeg NacosNamingService nacos-1.1.3/client @Override public void subscribe(String serviceName, EventListener listener) throws NacosException { subscribe(serviceName, new ArrayList<String>(), listener); } @Override public void subscribe(String serviceName, String groupName, EventListener listener) throws NacosException { subscribe(serviceName, groupName, new ArrayList<String>(), listener); } @Override
2.2K00发布于 2019-10-11 - 来自专栏韩曙亮的移动开发专栏
【EventBus】Subscribe 注解分析 ( Subscribe 注解属性 | threadMode 线程模型 | POSTING | MAIN | MAIN_ORDERED | ASYNC)
文章目录 一、Subscribe 注解属性 二、threadMode 线程模式 ( POSTING | MAIN | MAIN_ORDERED | BACKGROUND | ASYNC ) 一、Subscribe 注解属性 ---- 查看 Subscribe 注解的源码 , 其中定义了 3 个注解属性 ; threadMode 注解属性 用于配置 线程模式 , 用于标明执行事件对应的方法处于的线程类型 , java.lang.annotation.Target; @Documented @Retention(RetentionPolicy.RUNTIME) @Target({ElementType.METHOD}) public @interface Subscribe
1.7K10编辑于 2023-03-29 - 来自专栏Hello工控
MQTT Packet详解【03】：SUBSCRIBE & UNSUBSCRIBE
在下面介绍SUBSCRIBE、SUBACK、UNSUBSCRIBE和UNSUBACK的数据包结构时，您的问题将得到解答。 SUBSCRIBE Packet Structure SUBSCRIBE包结构 Fixed Header固定头 在SUBSCRIBE数据包中，固定报头中第一个字节的高4位必须设置为8（0b1000），而保留的低 Properties属性:下表列出了SUBSCRIBE数据包的所有可用属性。 Payload 载荷 SUBSCRIBE数据包的有效载荷包含一个或多个主题过滤器和订阅选项对。 一个原因代码对应于 SUBSCRIBE 包中的一个主题过滤器，因此 SUBACK 包中原因代码的顺序必须与 SUBSCRIBE 包中主题过滤器的顺序一致。 SUBSCRIBE 报文中的每个主题过滤器都与一组订阅选项相关联。
73210编辑于 2025-05-10 - 来自专栏AIGC
【AI绘画】Midjourney前置指令blend、info、subscribe详解
接下来，我们将继续深入/blend、/info和/subscribe前置指令的功能和使用方法。相信通过本篇文章，能够帮助你更好地掌握Midjourney前置指令的强大功能，提升AI绘画创作体验！ 通过一些便捷的前置指令，例如：/info、/subscribe你可以快速获取账号的状态、订阅详情等关键数据。这些指令不会影响图像生成的效果，但能够帮助你有效管理账户，保证创作体验。 Midjourney前置指令/subscrib /subscribe 是 Midjourney 的一个付费功能。通过点击这个命令，你可以管理账号的订阅状态。 总结来说，/subscribe 指令主要用于管理和购买 Midjourney 的订阅服务，与图像生成的参数设置无关。 小结 本文主要介绍了 Midjourney 的几个关键前置指令，包括 /blend、/info 和 /subscribe。
1.1K10编辑于 2024-10-17 - 来自专栏stream process
kafka consumer assign 和 subscribe模式差异分析
possible to use both manual partition assignment with assign(Collection) and group assignment with subscribe assign的方法不能和subscribe方法同时使用。 然后看一下具体实现源码： <! this.subscriptions.subscribe(new HashSet<>(topics), listener); ........... } ...... 内部调用了subscribe方法，assign内部调用了assignFromUser方法，看一下这两个方法的具体实现： private enum SubscriptionType { throw new IllegalStateException(SUBSCRIPTION_EXCEPTION_MESSAGE); } public void subscribe
2.9K10发布于 2020-03-04 MQTT 5.0 报文解析 03：SUBSCRIBE 与 UNSUBSCRIBE
SUBSCRIBE 报文结构固定报头在 SUBSCRIBE 报文中，固定报头中首字节的高 4 位值必须为 8（0b1000），而低 4 位保留位必须被设置为 2（0b0010）。 属性（Properties）：下表列出了 SUBSCRIBE 报文的所有可用属性。 一个 Reason Code 对应 SUBSCRIBE 报文的一个主题过滤器，所以 SUBACK 报文中 Reason Code 的顺序必须与 SUBSCRIBE 报文中主题过滤器的顺序一致。 UNSUBSCRIBE 报文结构固定报头与 SUBSCRIBE 报文相同，唯一的区别是报文类型字段的值从 8（0b1000） 变成了 10（0b1010）。可变报头与 SUBSCRIBE 报文相同。 总结SUBSCRIBE 和 SUBACK 报文用于订阅，UNSUBSCRIBE 和 UNSUBACK 用于取消订阅，想要订阅或者取消订阅的主题过滤器列表，都在对应报文的有效载荷中，SUBSCRIBE 报文中的每个主题主题过滤器
1.4K10编辑于 2024-05-09- 来自专栏前端开发
手动调用 Observable subscribe 的时机与案例探讨
有些时候, 手动调用 Observable 的 subscribe 方法, 才能完成更复杂或者更灵活的业务需求。 此时, 通过手动调用 subscribe 就能更加灵活地实现各种流程管理。 手动调用 subscribe 在这些场合就完全是不可或缺的做法。以下是一个简短的示例, 展示了如何在 Angular 应用中手动调用 subscribe 方法。 手动调用 subscribe 还能在调试阶段带来直观的好处。 手动调用 subscribe 既能避免过度使用模板逻辑, 也能在必要时完全接管数据流的管理过程。
22810编辑于 2025-07-29 - 来自专栏懒人开发
Eventbus3代码分析（四）：@interface Subscribe分析
---- @interface Subscribe分析 前面参考的代码，存放在（use_little_demo中的 eventbus3test） https://github.com/2954722256 用ctrl+鼠标左键， 跟进去，可以看见 @interface Subscribe @Documented @Retention(RetentionPolicy.RUNTIME) @Target({ElementType.METHOD }) public @interface Subscribe { ThreadMode threadMode() default ThreadMode.POSTING; /** --- priority() 我们暂时还没有用上， 我们通过看文档（或者对线程熟悉，名字就可以猜出来）， 可以了解到和对应的优先级有关 这里先不扯了 ---- 简单总结 @interface Subscribe
61960发布于 2018-09-12 - 来自专栏移动开发专栏
【解决问题的思路】its super classes have no public methods with the @Subscribe annotation
异常 Subscriber class xxx and its super classes have no public methods with the @Subscribe annotation 遇到异常不要慌 ，其实已经提示的很明显了，指定了具体的class，且明确告诉你这个类没有@Subscribe注解。 原因 但其实知道了问题后，可能依然会有疑惑，比如我，因为我这个类是有@Subscribe注解的，那是为什么呢？ 因为知道具体的class，也知道@Subscribe注解，所以很容易就能定位到是EventBus。 混淆规则，比如EventBus： -keepattributes *Annotation* -keepclassmembers class * { @org.greenrobot.eventbus.Subscribe
1.6K10编辑于 2022-06-10
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号