jjzjj

订阅者

全部标签

javascript - Apollo 订阅 - 处理 WS 与 subscribeToMore 断开连接

我一直在寻找一种方法来处理我的带有Apollo订阅的React应用程序中的网络套接字断开连接,但还没有找到这样做的方法。我在apollo文档中看到的其他示例显示了以下捕获重新连接的方法:constwsClient=process.browser?newSubscriptionClient(WSendpoint,{reconnect:true,}):null;constwsLink=process.browser?newWebSocketLink(wsClient):null;if(process.browser){wsLink.subscriptionClient.on('reconn

javascript - PushManager 订阅 promise 从不履行或拒绝

我目前遇到一些Chrome(Chromium)版本的问题,其中来自ServiceWorker的PushManager.subscribepromise保持挂起状态。代码本身非常简单:returnserviceWorkerRegistration.pushManager.subscribe({userVisibleOnly:true});我有一个有效且可访问的JSONlist,提供了GCM发件人ID。我还尝试了不同的实现,如thispost中所述,但结果还是一样。订阅部分适用于每个47+版本,该问题出现在较旧的版本中。(我正在使用Chromium连续构建来测试不同的主要版本)。另请注意,

javascript - 如何重启或刷新 Observable?

我有一个TypeScript/Angular2Observable,它在我第一次调用时就完美运行。但是,我有兴趣将多个订阅者附加到同一个可观察对象并以某种方式刷新可观察对象和附加的订阅者。这是我得到的:query():Rx.Observable{returnthis.server.get('http://localhost/rawData.json').toRx().concatMap(result=>result.json().posts).map((post:any)=>{varrefinedPost=newRefinedPost();refinedPost.Message=pos

javascript - RxJS 订阅者取消订阅与完成

我正在通读RxJS文档并想确保我理解Subscriber.unsubscribe()之间的区别。和Subscriber.complete().假设我有一个包含两个订阅者的可观察对象,subscriber1和subscriber2。如果subscriber1在其订阅上调用取消订阅,它将不再收到来自observable的通知,但subscriber2将继续接收它们。.complete()的文档:TheObservercallbacktoreceiveavaluelessnotificationoftypecompletefromtheObservable.NotifiestheObserv

javascript - RxJS 6 - 在管道中首次使用时是否需要取消订阅?

给定以下代码functiontriggerAction(){constasyncAction$=of("value1");asyncAction$.clientLogin().pipe(first(),tap(val=>console.log(`Test:${val}`)),).subscribe();}我需要退订吗?以前,当将first与修补运算符一起使用时,它们会在发出第一个事件后自行取消订阅,但从文档中无法立即清楚地知道等效的管道运算符是否也这样做。https://www.learnrxjs.io/operators/filtering/first.htmlhttps://rxj

javascript - 如何从 AsyncSubject(消费者模式)订阅一次元素

在rxjs5中,我有一个AsyncSubject并想多次订阅它,但只有一个订阅者应该收到next()事件。所有其他人(如果他们尚未取消订阅)应立即获得complete()事件,而无需next()。例子:letfired=false;letas=newAsyncSubject();constsetFired=()=>{if(fired==true)thrownewError("Multiplesubscriptionsexecuted");fired=true;}letsubscription1=as.subscribe(setFired);letsubscription2=as.sub

javascript - 在 Apollo Client 中取消订阅

在我的组件中,我有这段代码:componentDidMount(){//Setupsubscriptionlistenerconst{client,match:{params:{groupId}}}=this.propsclient.subscribe({query:HOMEWORK_IN_GROUP_SUBSCRIPTION,variables:{groupId},}).subscribe({next({data}){constcacheData=client.cache.readQuery({query:GET_GROUP_QUERY,variables:{groupId},})c

javascript - 等待 ServiceWorker 完成注册后再订阅

我正在使用ServiceWorker来实现用户通知。当用户首次访问该站点并批准通知时,ServiceWorker将注册并订阅:if('serviceWorker'innavigator){console.log('ServiceWorkerissupported');navigator.serviceWorker.register('/js/sw.js').then(function(reg){if(/chrom(e|ium)/.test(navigator.userAgent.toLowerCase())){reg.pushManager.subscribe({userVisible

javascript - 取消订阅 FCM Web 中的主题

我在我的网站中成功设置了FCM,并且运行良好。我正在使用JavaScript通过订阅向“电影”主题发送通知。fetch('https://iid.googleapis.com/iid/v1/'+tokenz+'/rel/topics/movies',{method:'POST',headers:newHeaders({'Authorization':'key=****'})我没有找到任何文档来使用JS在网络中取消订阅主题。取消订阅单个主题的最佳方式是什么?还有什么方法可以取消订阅所有主题? 最佳答案 好问题。我从来没有真正意识到没有

go - 如何在 Golang 中订阅多个 channel

它使用golang的channel。以下代码如何使st2正常显示:packagemainimport("fmt""github.com/OpinionatedGeek/go-bittrex")funcmain(){bt:=bittrex.New("","")ch:=make(chanbittrex.ExchangeState,16)gofunc(){forst:=rangech1{fmt.Println("Message:",st)}forst2:=rangech2{fmt.Println("Message:",st2)}}()bt1.SubscribeExchangeUpdate("