草庐IT

reactivity

全部标签

ios - 在 uibutton 中绑定(bind) Action -Reactive Cocoa

我已经声明了一个ActionvarpostAction:Action!现在我想要的是在按钮触发时触发此操作。triggerBtn.reactive.pressed=CocoaAction(postAction)但不能。当使用react性cocoa按下按钮时,我如何触发某些Action?我想出了一种观察Action的方法。self.testBtn.reactive.trigger(for:.touchUpInside).observe{eventin//dosomethingprint(event)}但不知道如何获取发件人并绑定(bind)自定义操作? 最佳答

swift - 如何通过 reactive(RxSwift) 调用替换 UICollectionViewDelegateFlowLayout?

有没有办法替换方法funccollectionView(_collectionView:UICollectionView,layoutcollectionViewLayout:UICollectionViewLayout,sizeForItemAtindexPath:IndexPath)->CGSize从UICollectionViewDelegateFlowLayout协议(protocol)通过一些使用RxSwift的react? 最佳答案 返回值的协议(protocol)方法是基于拉的,因此与Rx基于推的哲学不兼容。目前不仅不

java - 响应式(Reactive)编程是否受限于函数式编程?

关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想知道响应式编程与函数式编程有何关联。大多数论文将“响应式(Reactive)编程”称为“函数式响应式(Reactive)编程”。是否可以在函数式编程之外实现响应式编程?用函数式语言编写响应式(Reactive)程序更容易吗?

ios - 如何在通知中使用 Reactive Cocoa

如何根据通知名称创建信号?例如,我想从:[[NSNotificationCenterdefaultCenter]addObserver:selfselector:@selector(userDidChange:)name:kTTCurrentUserLoggedOffNotificationobject:nil];类似于:[signalForName(kTTCurrentUserLoggedOffNotification)subscribeNext:^(idx){...}]; 最佳答案 -[NSNotificationCenterr

java - Lettuce:响应式(Reactive) API 的共享连接

我正在将我当前的项目从Jedis移植到Lettuce。可以为响应式API使用共享连接吗?只要我不调用阻塞和事务性操作,例如BLPOP和MULTI/EXEC?我应该为通过响应式(Reactive)API的事务使用连接池吗?是否可以通过响应式API来管道化命令?我应该为此使用专用连接吗? 最佳答案 在多个线程之间共享一个连接是预期用途。有多种原因:连接是线程安全的。Redis是单线程的。对一台主机使用多个连接显然没有意义,因为由于缺乏Redis处理并行性,没有性能提升。连接池打开多个连接。虽然这对于事务和阻塞命令隔离可能有意义,但池化可

java - 如何在 Spring Data Redis Reactive 中使用事务?

我正在尝试使用spring-data-redis2.1.8中的ReactiveRedisOperations来执行事务,例如:WATCHmykeyval=GETmykeyval=val+1MULTISETmykey$valEXEC但在浏览docs时,我似乎无法找到执行此操作的方法或ReactiveRedisOperations。这在响应式(Reactive)客户端中不可用,还是如何实现? 最佳答案 TL;DR:没有对使用ReactiveAPI的Redis事务的适当支持原因在于执行模型:Redis如何执行事务以及响应式(Reactiv

c# - 使用 Reactive Extensions (Rx) 进行套接字编程实用吗?

用Rx编写GetMessages函数最简洁的方法是什么:staticvoidMain(){Socketsocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);varmessages=GetMessages(socket,IPAddress.Loopback,4000);messages.Subscribe(x=>Console.WriteLine(x));Console.ReadKey();}staticIObservableGetMessages(Socketsocket,IPAd

c# - System.Reactive.Joins 指南

我正在寻找System.Reactive.Joins的介绍/一些文档,其中包括Pattern、Plan、QueryablePattern和QueryablePlan类。Google没有找到任何东西(“System.Reactive.Joins”),MSDN什么也没有,没有样本here,以及来自thisquestion的优秀资源不要覆盖这个命名空间。有没有人有一些指点? 最佳答案 找到了一个很好的SO问题,它显示了用法,但对我来说,计划和模式的总体目的是创建一个可观察的组合单元,而不是一个组合的可观察的。语义,我知道,但对我来说,使用

c# - 响应式(Reactive)扩展是否支持滚动缓冲区?

我正在使用响应式扩展将数据整理到100毫秒的缓冲区中:this.subscription=this.dataService.Where(x=>!string.Equals("FOO",x.Key.Source)).Buffer(TimeSpan.FromMilliseconds(100)).ObserveOn(this.dispatcherService).Where(x=>x.Count!=0).Subscribe(this.OnBufferReceived);这很好用。但是,我想要的行为与Buffer操作提供的行为略有不同。本质上,如果收到另一个数据项,我想重置计时器。只有当整个1

C# .NET Rx-System.Reactive 在哪里?

我有很强的Java背景,所以如果我忽略了C#中一些明显的东西,请原谅我,但我的研究毫无进展。我正在尝试使用响应式(Reactive)Rx.NET库。编译器不会提示IObservable,而是提示zip方法的调用。它抛出“...您是否缺少using指令或程序集引用?”我一直在浏览命名空间,但找不到要查找的内容。我找不到System.Reactive,如果使用它也会引发错误,并且此Windows8.1应用程序已包含所有引用。有人可以告诉我哪里出了问题吗?publicsealedclassEventEngine{privatestaticreadonlyEventEnginesingleto