订阅内部延迟/订阅后延迟

文章/答案/技术大牛

发布

1回答

javascript、angular、rxjs、rxjs-observables

我在subscribe中设置了isUpdate标志为真，我必须在一段延迟后将其设置回假，以便我可以显示一个快速弹出窗口我尝试过使用.pipe(delay(2000)).subscribe，但是整个回调被延迟了

浏览 9提问于2019-10-03得票数 0

回答已采纳

2回答

在执行函数之前使用rxjs添加延迟

angular、typescript、rxjs

我有一个订阅，需要在从该订阅中获得值之后运行一个函数( getDetails() )。但需要延迟才能调用该函数。目前我使用的是setTimeout()事件。但我需要把它转换成rxjs的方式。//data handling logic this.getDetails(); }); 更新:在处理身体内部的数据后，我需要一个延迟。

浏览 7提问于2022-08-05得票数 0

回答已采纳

2回答

ClojureScript重帧订阅取消引用困境

clojurescript、dereference、reagent、re-frame

外部订阅，早期deref [:p msg])) [component @msg](defn component [msg] [componentmsg](defn component [] (

浏览 2提问于2017-09-12得票数 7

回答已采纳

2回答

NServiceBus:在发布之前，强制发布者在启动时处理订阅请求

nservicebus

根据我的观察，当内部NSB运行时启动时，它将在一个单独的线程(而不是接收发布请求的线程)上开始处理订阅请求，延迟几秒钟。那么在这个场景中，新的订阅者虽然在“商店开张”之前提交了他们的订阅请求，但仍然会错过“商店开张”之后的前几个发布。如何强制NSB仅在流程开始时完成队列中已提交的所有订阅请求后才执行第一次发布？

浏览 3提问于2014-09-26得票数 0

1回答

为什么在.delay中使用组合框架破坏这段简短的代码？

ios、swift、sequence、combine

textColor = $0 } }它起作用了，因为我在几千秒内浏览了列表，如果我不尝试以延迟来减缓这个过程

浏览 5提问于2021-02-11得票数 0

回答已采纳

1回答

是否可以在Oracle AQ上实现指数级重试延迟？

oracle、oracle11g、advanced-queuing

我想了解是否可以在Oracle AQ订阅上设置指数重试延迟我使用发布和订阅方法，其中订阅是同一数据库中的l_queue_name,max_retries => 3,retention_time => 1209600); 重试延迟是一个常量

浏览 3提问于2014-02-04得票数 1

1回答

等待链式延迟完成

jquery

我想知道链式延迟最好的设计是什么。components and pass them args},{},{ document.getElement

浏览 1提问于2012-06-29得票数 1

回答已采纳

2回答

RxJs扩展和延迟操作员不按预期工作

angular、typescript、rxjs、rxjs-pipeable-operators

} });除了一件事外，一切正常工作:即使我用一个delay返回下一个调用(内部展开) .getStatus(entity)第一个电话没有延迟，我不明白为什么

浏览 8提问于2022-10-26得票数 3

回答已采纳

1回答

Nservicebus延迟发布事件

nservicebus、azureservicebus

有没有一种方法可以延迟事件的发送，或者设置一些属性来确保消息在主题订阅延迟后出现？主机在注意到主数据库中的更改后发出事件。主数据写入复制到多个辅助数据库中。接收者也是使用nservicebus主机并订阅主题的azure工作者角色。一种选择是使用主数据库读取，但这是我不想采用的路线。

浏览 4提问于2016-10-28得票数 2

2回答

RxJ如何创建可观察对象流，延迟后只订阅最后一个

angular、typescript、rxjs、observable

我有三个主机监听器，之后我订阅了一个可观察对象，我想知道这是否可能，如果是这样的话，我可以创建一个具有延迟的可观察对象流，并在延迟后只订阅最后一个。而不是observable form event，并将其组合在一起，所以如果这样的事情可能发生，以及如何实现，请帮助我，这样this.authenticationService.refresh()只会在延迟一秒后被调用一次

浏览 0提问于2020-11-18得票数 1

2回答

使用RxSwift可观测值的递归调用

ios、swift、rx-swift

return .just(item) }_ = observeUntil(initialValue: 0)当我在上面的代码中注释延迟时current item is 2current item is 4Program ended with exit code: 0current item is 0请帮助我理解当

浏览 11提问于2019-11-19得票数 1

1回答

具有一些即时订阅和一些延迟订阅的Azure Service Bus主题

azureservicebus

一些订阅者必须立即处理。一个或多个订阅者必须在第二天才开始处理。我曾研究过使用BrokeredMessage.ScheduledEnqueueTimeUTC属性来延迟对队列和主题上的消息的处理，但这意味着所有订阅者都会延迟它们的处理。我的想法是，我应该在不延迟入队时间的情况下将BrokeredMessage添加到主题中，并在一个订阅者上创建一个函数，该函数创建一个具有延迟入队时间的新BrokeredMessage，并将其添加到另一个队列是我疯了，还是有

浏览 11提问于2018-07-25得票数 0

回答已采纳

1回答

Ngrx订阅未跨惰性边界调用

ngrx、ngrx-store

AppModule中的任何导航都会导致调用reducer，更新状态中的lastRouterUrl，然后调用上面的订阅。但是，我也有一些延迟加载的功能模块，当这些模块被导航到时，当用户在延迟模块内部的路由中导航时，会发生以下情况。而且，如果我将上面的订阅移到lazy模块本身，一切都会正常工作！似乎懒惰/急切模块边界之间的任何分派和订阅者都是相互排斥的，即，如果订阅者在另一个模块中，则发生并导致状态更改的分派不会通知正在侦听该更改的订阅者。如何

浏览 0提问于2018-04-26得票数 0

3回答

RxJava -延迟和delaySubscription有什么区别？

java、rx-java、rx-java2

我试图理解延迟和操作符之间的区别。 Observable observable = Observable.just(5, 3, 4, 2);observable

浏览 0提问于2018-03-25得票数 11

回答已采纳

1回答

如何在ZMQ发布服务器/订阅服务器队列中获取消息/事件计数

zeromq、publish-subscribe、pyzmq

但是，由于订阅者的处理时间，消息会被延迟处理(有时，由于排队消息的数量，延迟以小时为单位)。为了克服这一延迟，我计划根据发布队列中挂起的消息的数量，扩大/减少订阅者的进程。目前，我正在考虑使用发行者-服务器内存利用率阈值来扩大/减少订阅者进程。

浏览 3提问于2020-02-06得票数 0

1回答

SNS将消息传递给已删除的订阅

amazon-web-services、amazon-sns

我有一个带有HTTPS订阅的SNS主题。端点是一个API，它代理Lambda函数，它格式化SNS消息并将其转发到web钩子(聊天室)。我是通过跟踪来测试取消订阅功能的，并发现了看似不正确的行为。我看到XML响应(在浏览器中)表示已执行取消订阅请求。我确认取消订阅请求已经执行，方法是转到AWS控制台，查看SNS主题，并看到订阅现在被列为“已删除的”(以前它有一个ARN和一个提供的链接)。我进一步确认订阅请求已经执行，因为我可以看到接收到的。但是，随后当我向该主题发布消息(无论是通

浏览 5提问于2020-01-28得票数 0

2回答

大查询与查询&本地搜索与多个数据库查询

mysql、database、performance

订阅者：subscriber_id，description，callback_url，callback_parameters，auth_token 支持:相对较小的网络流量(存在一些冗余) 对于每个重大更改:

浏览 3提问于2015-07-20得票数 0

回答已采纳

1回答

在使用长轮询检索实时通知时，是否有可能丢失事件？

notifications、real-time、cumulocity

当订阅实时通知时，我会进行正常的握手、订阅、连接流.一旦连接与事件一起返回，我将重新连接并等待下一个响应返回。我的问题是：，如果事件产生了第一个响应和下一个重新连接，它们会丢失吗？例如:同步应用程序在返回后处理返回的响应数据，并且只有在数据处理完成后才重新连接，这可能会导致响应与下一个重新连接之间的严重延迟。在该延迟期间生成的累积事件是在该特定客户端id的实时队列中缓冲，还是它们刚刚丢失？另一个可能的例子是，当客户端ID不再有效时(这似乎每天在午夜发生)，我必须重新订阅，导致一段时间内

浏览 2提问于2016-03-07得票数 0

回答已采纳

2回答

公共交通的订阅服务是一个单一的失败点

msmq、soa、masstransit

我需要使用订阅服务，因为我不能使用多播，因为：我认为这违背了消息队列的思想，即消息一直保存到接收方可用为止。我认为与订阅服务的通信是通过mt_subscriptions队列完成的，并且启动将不依赖于订阅服务的运行。

浏览 1提问于2014-05-23得票数 2

回答已采纳

1回答

如何在事务性复制中检查发布服务器和订阅服务器？

sql-server、replication、transactional-replication

在事务性复制中，如何在特定的时间点检查和确认发布服务器和订阅服务器上的数据是否相同？我不想检查延迟/跟踪令牌，因为延迟只会告诉订阅者在发布服务器/分发服务器上落后了多少？

浏览 2提问于2016-06-28得票数 0

回答已采纳

点击加载更多