reactive

1熱度

2回答

獲取第一個IObservable事件而不阻塞想要它的線程/任務

我正在尋找使用IObservable在請求響應環境中獲取響應的方法，並替換一些較老的基於回調的代碼，但我發現如果將值推入（Subject.OnNext）到可觀察值但FirstAsync尚未處於等待狀態，則FirstAsync將永遠不會被提供該消息。 是否有直接的方式使它工作，沒有第二個任務/線程加同步？ public async Task<ResponseMessage> Send(Request

c# multithreading reactive 2017-07-14

---

0熱度

1回答

如何在角2

禁用反應形式屬性具有一個反應性形式，我採取一個陣列內形成我的實現是像 testForm:FormGroup; fb is instance of FormBuilder; this.testForm=this.fb.group({ testarray:this.fb.Array([ note:[''] ]) }) 我使用上述陣列上我的HTML來顯示註釋。這裏的功能就像用戶可以

angular2-forms disabled-control reactive 2017-07-16

---

0熱度

1回答

無功網絡 - ANdroid更改默認ping主機

我有使用com.github.pwittchen.reactivenetwork.library的應用程序。 Cos應用程序是爲了在中國工作，防火牆禁止主機：google.com。 如何更改或覆蓋： private static final String DEFAULT_PING_HOST = "www.google.com"; 我不能改變進口框架HOST。 我Application.java

android networking reactive 2017-07-18

---

1熱度

2回答

使用被動擴展處理將密鑰合併到1秒的事件更新

我以150-200次更新/秒的速度得到更新事件。我想把這個混淆爲每個鍵1秒。 實施例：在圖1第二I收到3個鍵A，B，C的更新中的順序：A1，B1，C1，A2，A3，B2 我想處理這個更新每1秒&僅處理來自上述示例的A3，B2 & C1。 如何使用Reactive擴展來解決這個問題？ 到目前爲止，我嘗試過： Observable.FromEventPattern<EventArgs>(_listen

c# events system.reactive reactive 2017-07-19

---

0熱度

1回答

春季數據MongoDB save（）結果雙重插入

我們遇到了以下行爲，但我們希望知道它是否是預期的，以及是否有興趣將它記錄爲一些有種陷阱。 我們與春天啓動2 /春WebFlux試驗和設置了一個小的應用程序，主要有這樣的事情（所有縮短）： @PostMapping public Mono<Todo> addTodos(@RequestBody Person person) { return personService.addPerson

spring spring-mvc spring-data-mongodb reactive project-reactor 2017-07-25

---

0熱度

1回答

當用戶添加到集合中時，流星不會重新渲染

當新用戶添加到用戶集合中時，雖然我可以在websocket中看到該html，但它不會重新渲染。 websocket message publication.js： Meteor.publish('users.name.by-game', function(code) { check(code, String); this.autorun(function() { co

javascript reactjs meteor reactive 2017-08-01

---

2熱度

1回答

使反應卡夫卡與合流模式註冊的Avro模式

工作，如何使無功卡夫卡（https://github.com/akka/reactive-kafka）與合流模式註冊的Avro模式工作？下面是我的示例代碼： def create(groupId: String)(implicit system: ActorSystem): Source[ConsumerMessage.CommittableMessage[String, Array[Byte]]

akka apache-kafka avro reactive 2017-06-19

---

1熱度

1回答

[R閃亮 - 如何創建作出反應，通過時間單位根據時間單位（周，月，年）和聚合數據的barplot

我生成有關下列變量疾病數據幀： 日期（發病時間） 例（例數，默認情況下，案件數爲1） 周（疾病情況下一週） 月（疾病情況下一個月） 年（一年的病例）。 我的UI是在這裏： library(shiny) library(dplyr) library(lubridate) library(ggplot2) library(scales) Disease<-data.frame(Date=s

r date shiny dplyr reactive 2017-06-21

---

0熱度

1回答

同步觀測的HTTP調用

我有一個調用的OData如下刪除服務的刪除方法： deleteValues = (key) => { return new Promise((resolve, reject) => { ... this._referenceDataService.deleteReferenceData(etag, url).subscribe( data => {

angular rxjs angular2-services angular2-observables reactive 2017-06-21

---

5熱度

1回答

Spring Reactive WebClient

我有一個被動rest api（webflux），也使用spring WebClient類來請求來自其他休息服務的數據。 簡化設計： @PostMapping(value = "/document") public Mono<Document> save(@RequestBody Mono<Document> document){ //1st Problem: I do not know ho

java project-reactor reactive 2017-06-22

---