- r - 以节省内存的方式增长 data.frame
- ruby-on-rails - ruby/ruby on rails 内存泄漏检测
- android - 无法解析导入android.support.v7.app
- UNIX 域套接字与共享内存(映射文件)
向特定 channel 发布消息。
redis 127.0.0.1:6379> PUBLISH channel message
(integer) 0
我使用另一个 Redis 客户端订阅了 channel 。
redis 127.0.0.1:6379> SUBSCRIBE channel
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel"
3) (integer) 1
在 Redis 客户端中,我获得了所有已发布的消息。现在我想退订订阅的 channel 。但我无法在 Redis 客户端中输入取消订阅。当我使用 Ctrl+c 时,Redis 客户端完全退出。 Redis客户端的退订命令怎么写?
最佳答案
我不认为你可以在客户端发出取消订阅,因为客户端被阻止了。我写了一个 ruby 脚本来展示如何使用取消订阅。
require 'redis'
r = Redis.new
r.subscribe 'first' do |on|
on.message do |e, d|
puts e
puts d
r.unsubscribe
end
end
puts "script was blocked?"
如果删除 r.unsubscribe,脚本将被阻止。你可以添加 if 子句来检查何时取消订阅 client.ex:
r.unsubscribe if d == 'leave'
关于redis - 如何在 Redis 2.6.11 中使用 UNSUBSCRIBE 命令,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15633634/
更新协程1.3.0-RC 工作版本: @FlowPreview suspend fun streamTest(): Flow = channelFlow { listener.onSomeRe
我想在我的服务发送的电子邮件的页脚中提供一个单击“取消订阅”链接。 显然,许多垃圾邮件扫描程序会扫描电子邮件,并会按照电子邮件中的任何链接扫描其内容中的恶意软件。到目前为止我使用的解决方法: 如果“取
我有一个 mailgun 帐户并一直用它来发送电子邮件。我启用了自动“取消订阅”功能,这样从我的帐户发送的所有电子邮件都会有“取消订阅”链接。 但是,我有一封电子邮件,我只想发送一次,并且希望禁用这封
ObjectUnsubscribedError: object unsubscribed,有时(不是每次)在文本框中输入任何值 HTML 组件.ts clearFilter(newValue) {
sub.unsubscribe 不删除 channel ,如何交替删除 channel ? 我尝试了 channel.close() 或 channel.quit() 但没有用! 代码: let ro
首次安装时,应用程序运行没有任何问题。 在启动画面检查登录状态。 用户未登录,导航到登录屏幕。 但 unsubscribe() 不是函数 当应用程序最小化然后重新打开时,错误显示并停留在启动画面。这只
我正在寻找一个发布/订阅系统,可以让我修改当前的订阅。我找不到任何东西,所以我想我应该构建自己的(用 JavaScript)。 我有发布和订阅的基本方法,如下所示: ps.publish(params
我有一台 Mac,使用 CoreBluetooth 作为 CBPeripheralManager 设置为蓝牙配件。 Mac 在一组特征 CBUUID 上做广告,一旦它有了订阅者,我就单击一个按钮,每半
我在收到可观察到的第一个项目后尝试取消订阅。而且这似乎行不通。我做错了什么? public class ObservableAndSubscriber { public static
您可能都知道需要取消订阅 Observables 以防止内存泄漏。 我不明白为什么不为使用 Observables 的组件类创建 @Uncsubscribe 装饰器,它将遍历所有属性并取消订阅 des
试图制作一个简单的计时器并且需要在某些if 条件下中断它。但总是出现错误 EXCEPTION: timer.unsubscribe is not a function。 我做错了什么? let
我正在尝试掌握 rxJS 中的订阅和可观察对象。 我想通过取消订阅来更改 Observable 的间隔,然后使用新的间隔设置重新订阅。 应该非常简单,但由于我是这方面的初学者,我可能需要一些帮助。 查
这个问题在这里已经有了答案: Difference between .unsubscribe to .take(1) (2 个答案) Angular/RxJS When should I unsub
我有一个依赖属性 (bool),它可以在文本框中启用行为。 属性更改回调订阅了一些事件处理程序: static void MyPropertyChanged(DependencyObject d, D
我使用Observable.create()创建一个可观察对象以在调度程序上执行一些工作(例如Schedulers.io(),然后在AndroidSchedulers.mainThread()上返回结
我想知道,在使用 unsubscribe 后,使用 .take(1) 和 .unsubscribe 之间的性能是否有任何差异订阅: var observable = Rx.Observable.int
我正在使用 ng2-stomp-service 订阅套接字: this.fooSubscription = this.stomp.subscribe('/topic/foo', (res) => {
我正在使用 ng2-stomp-service 订阅套接字: this.fooSubscription = this.stomp.subscribe('/topic/foo', (res) => {
我在 angular tutorial 中发现了奇怪的结构.返回部分发生了什么?代码块内的函数调用后跟空对象? // This function runs when subscribe() is ca
有没有一种方法可以编写单元测试来检查我是否已成功取消订阅我的 Observable 订阅? 我正在使用 ngx-auto-unsubscribe . 示例: @AutoUnsubscribe() @C
我是一名优秀的程序员,十分优秀!