reactive

0热度

1回答

如何与执行等到观察员BehaviourSubject完整//角2个RxJS

我的代码与跨应用许多观察家BehaviorSubject。 在BehaviorSubject上创建.next（）时，如何知道所有已注册的观察者何时已完成执行。

angular reactive behaviorsubject 2017-04-04

---

1热度

1回答

订阅同一用户在rxJava 2

在rxJava 1.x中有可能做这样的事情：也返回Observable<Foo> 我无法找到同样的方法 Observable.<Foo>create(subscriber -> { ... getNewObservable().subscribe(Subscribers.wrap(subscriber)); }) GetNewObservable（）在rxJava中2.在

rx-java observable subscribe rx-java2 reactive 2017-04-10

---

0热度

1回答

当发送给分片演员时，对ReactiveKafka的背压

我已经编写了一个Akka应用程序，该应用程序从Kafka获取输入，然后使用分片演员处理数据并输出到Kafka。 但在某些场合分片区域不能处理负载，我也得到： 你或许应该实行流量控制，以避免水浸 远程连接。 如何在此链/流中实施背压？ 卡夫卡消费 - >共享演员 - >卡夫卡生产者 从代码一些片断： ReactiveKafka kafka = new ReactiveKafka(); Subsc

akka apache-kafka actor reactive backpressure 2017-04-10

---

0热度

1回答

更新SelectInput而不触发反应？

我是新来的闪亮但有点像它。现在我有一个需要帮助的有趣问题。我有一个数据库可以通过indexA和indexB查询，但不是两者。也就是说，如果我使用selectInput从一个索引（例如indexA）检索数据，则必须将另一个索引（在本例中为indexB）设置为默认值（B0），反之亦然。输出小部件取决于两个selectInput。因此，如果我交互一个selectInput来查询数据，我需要更新另一个se

shiny reactive 2017-04-11

---

1热度

2回答

缓冲组按组进行反应扩展，嵌套订阅

我有一个事件源生成属于某些组的事件。我想缓冲这些组并将这些组（批量）发送到存储。到目前为止，我有这个： eventSource .GroupBy(event => event.GroupingKey) .Select(group => new { group.Key, Events = group }) .Subscribe(group => group.Events

c# .net system.reactive reactive 2017-02-24

---

0热度

1回答

shinydashboard中的下拉菜单中的被动对象

是否可以根据反应对象呈现仪表板标题下拉菜单或通知项目？我的尝试没有奏效。 library(shiny) library(shinydashboard) ui <- dashboardPage( dashboardHeader(uiOutput("drop")), dashboardSidebar(), dashboardBody() ) server <- f

r shiny shinydashboard reactive 2017-02-24

---

1热度

1回答

Flux级联不返回

我正在试验Spring Boot 2.0，webflux和重新激活的Mongo仓库。我有两种第一种删除方式，然后将数据添加到集合中。在第一种变体中，线程阻塞直到删除完成，在第二种变体中，将数据的添加连接到删除。 变体A @GetMapping("init") public String init() { Random rand = new Random(); Flux<Pow

mongodb spring-boot spring-data-mongodb reactive spring-webflux 2017-02-28

---

1热度

1回答

响应式编程的可扩展性

如果响应式编程避免使用线程并使用对象之间的异步消息传递，如何管理可伸缩性？ 如何决定何时需要新实例？ 是否有一些透明地管理这个API？

scalability reactive 2017-03-07

---

1热度

2回答

互动情节和reactiveValues

我真的很感激一些帮助，下面的代码： library(shiny) library(rhandsontable) library(tidyr) dataa <- as.data.frame(cbind(rnorm(100, sd=2), rchisq(100, df = 0, ncp = 2.), rnorm(100))) ldataa <- gather(dataa, key="vari

r shiny interactive reactive rhandsontable 2017-03-11

---

3热度

2回答

Angular2反应形式选择如何设置无效？

我在我的应用程序中使用反应形式。在一定的形式我想显示需要（Validators.required）选择这样的： <select class="form-control" [id]="dformControl.key" [formControlName]="dformControl.key" [multiple]="dformControl.multiple">

forms angular select reactive 2017-03-28

---