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

---