草庐IT

rx-javafx

全部标签

java - 从 JavaFX 程序为 WebView 执行 Javascript 函数

我正在尝试从Java程序执行Javascript函数。Javascript函数获取HTML文件的内容并突出显示特定单词的出现。是否可以从webview对象调用Javascript函数? 最佳答案 要在WebView中运行javascript,您可以使用WebEngine.executeScript()方法。并且有很多方法可以通过javascript突出显示文本。例如。HighlightwordinHTMLtext(butnotmarkup)一起:WebViewwebView=newWebView();finalWebEngineen

javascript - 错误后可观察到 rx 损坏

我正在尝试使用ngrxstore+ngeffects为我的应用程序编写登录流程。我设法编写了它并且它在快乐的场景中工作,但是当用户向表单输入错误的值时,服务器以401响应,下一次登录尝试无效。我读到在使用可观察对象时必须捕获异常,以免“中断”流,但据我所知,我捕获了异常并且它现在仍在工作。代码下方;exportclassLoginComponent{logged=newObservable();constructor(privatestore:Store){this.logged=store.select('login');}login(username:string,password

javascript - rxjs 在 map Rx.Observable.range(1, 5).map 中使用 async/await

我想使用async/await从rxjs获取列表。我该怎么办?functiongetData(num){returnnewPromise((resolve,reject)=>{resolve(num+1)})}asyncfunctioncreate(){varlist=awaitRx.Observable.range(1,5).map(async(num)=>{constdata=awaitgetData(num)returndata}).toArray().toPromise()returnlist}Rx.Observable.fromPromise(create()).subscr

javascript - 如何从 `Observable` 导入 `Rx`(非 Angular )

我正在使用SystemJS将我的es2015项目加载到浏览器中。这是我做的import{Observable}from'rxjs/Rx';constbutton=document.querySelector('button');conststart$=Observable.fromEvent(button,'click');在这种情况下,Observable是undefined。所以我尝试了importObservablefrom'rxjs/Observable';在这种情况下,Observable是一个对象,但是Observable.fromEvent是undefined(它似乎是一

javascript - 如何将 Node 可读流转换为 RX 可观察流

如果我有一个Nodejs流,例如来自process.stdin或fs.createReadStream,我如何将其转换为RxJsObservable使用RxJs5流?我看到了RxJs-Node有一个fromReadableStream方法,但看起来它已经将近一年没有更新了。 最佳答案 对于任何正在寻找这个的人,根据Mark的建议,我为rxjs5改编了rx-nodefromStream实现。import{Observable}from'rxjs';//Adaptedfromhttps://github.com/Reactive-Ext

javascript - Typescript 使用 Rx.js 过滤器运算符区分联合类型?

typescript支持discriminatedunions.如何将与Rxjs相同的概念扩展到filter下面例子中的运算符?interfaceSquare{kind:'square';width:number;}interfaceCircle{kind:'circle';radius:number;}interfaceCenter{kind:'center';}typeShape=Square|Circle|Center;constobs$:Observable=of({kind:'square',width:10});//Expectedtype:Observable//Actu

javascript - 如何避免 Rx 中的故障

与其他“FRP”库不同,Rx不会防止故障:使用时间不匹配的数据调用的回调。有解决此问题的好方法吗?举个例子,假设我们有一系列从单个流派生的昂贵计算(例如,我们在下面进行排序或ajax获取,而不是_.identity)。我们执行distinctUntilChanged以避免重新计算昂贵的东西。sub=newRx.Subject();a=sub.distinctUntilChanged().share();b=a.select(_.identity).distinctUntilChanged().share();c=b.select(_.identity).distinctUntilCha

javascript - JavaFX WebView 禁用同源策略(允许跨域请求)

我正在开发一个主要是美化网页的JavaFX应用程序。它是一个桌面应用程序(它没有嵌入到网页中)并且它有一个用于主UI的WebView。该应用程序本身的唯一目的是使用Bluecove访问蓝牙设备,因为在Web浏览器上直接使用JavaScript是不可能的。概念验证工作正常(我能够从Java调用JavaScript代码,反之亦然)但我有一个额外的要求,即从JavaScript中调用任意Web服务/API,但这违反了同源策略(类似于这在Android上:AllowremoteajaxcallsinanAndroidWebview+jquerymobile)。这在JavaFX上可行吗?有什么建

javascript - Rx debounce operator with first 和 last

是否有任何rx运算符的组合以获得第一个和最后一个去抖动事件?这将用于主细节场景(甚至是搜索场景),在这些场景中,我们希望在用户停止更改选择后立即加载第一个选定项目和最后一个选定项目。这将防止在用户缓慢导航时注入(inject)去抖动时间,同时也防止突发变化。如果debounce运算符(operator)有一个“立即”选项,如underscore.jsdebouncefunctoin然后合并2个版本的debounce运算符将生成所需的结果。 最佳答案 要获得第一个去抖动的元素,您可以使用throttle.要获得最后一个,您可以使用de

javascript - Rx distinctUntilChanged 允许在事件之间的可配置时间后重复

让我们考虑一下下面的代码Rx.Observable.merge(Rx.Observable.just(1),Rx.Observable.just(1).delay(1000)).distinctUntilChanged().subscribe(x=>console.log(x))我们希望1只记录一次。然而,如果我们想要允许重复一个值,如果它的最后一次发射是在可配置的时间之前呢?我的意思是记录这两个事件。例如,如果有类似下面的东西会很酷Rx.Observable.merge(Rx.Observable.just(1),Rx.Observable.just(1).delay(1000)).