首页 > TAG信息列表 > reactivex
Angular初学（二）
一、Rxjs介绍 RxJS是ReactiveX编程理念的JavaScript版本。ReactiveX来自微软，它是一种针对异步数据流的编程。简单来说，它将一切数据，包括HTTP请求，DOM事件或者普通数据等包装成流的形式，然后用强大丰富的操作符对流进行处理，使你能以同步编程的方式处理异步数据，并组合不同的操作符来轻javascript-创建后更改可观察的时间间隔/设置
在RxJS中,创建后如何更改间隔设置？ 到目前为止,我有这个,但是没有用 var observable = Rx.Observable.interval(500) .map(function (data) { return "Hello World " + data; }); observable.subscribe(console.log); setTimeout(function () { observable.interval(3000); }NancyFx And ReactiveX
http://reactivex.io/ https://github.com/dotnet/reactive http://nancyfx.org/ NancyFX Nancy快速上手 （使用Nancy模板） Nancy是.NET 平台的微框架。在受到Ruby社区的Sinatra框架启发下，NancyFx框架提供一个.NET平台下的低门槛、易上手的可用于Web开发工具包。 请注意我javascript-RxJs Observable完成多次
以下是反应式代码(RxJs)的简短代码段 let subj = new Rx.Subject(); let chain = subj .switchMap(v => Rx.Observable.of(10*v).do(vv => console.log("Switch map", vv))) .share() .take(1); function subscribe(){ chain.subscribe(v => console.lo使用ReactiveX for Java进行Http调用
我是ReactiveX for Java的新手,我有以下代码块来进行外部http调用,但它不是异步的.我们使用的是rxjava 1.2和Java 1.8 private ResponseEntity<String> callExternalUrl(String url, String json, HttpMethod method) { RestTemplate restTemplate; HttpEntity request购物车工具类逻辑
package com.bawie.gouwuche.model.http; import android.util.Log; import com.bawie.gouwuche.IApi; import com.bawie.gouwuche.model.bean.CartBean; import java.util.concurrent.TimeUnit; import io.reactivex.Observable; import io.reactivex.Observer; import ioRxJava2：首先替代rx.Observable方法(谓词)
我想使用RxJava但不能提出替代方法 public final Observable<T> first(Func1<? super T,java.lang.Boolean> predicate) 在RxJava2中. 我想做的是： return io.reactivex.Observable .concat(source1, source2, source3, source4) .first(obj -> obj != null); 参数sourcandroid – Kotlin：如何检查带有lateinit属性的变量是否已初始化
我有一个声明为的变量 private lateinit var apiDisposable: Disposable 然后在onPause()方法中,我正在做 override fun onPause() { super.onPause() if (!apiDisposable.isDisposed) apiDisposable.dispose() } 但我明白了 kotlin.UninitializedPropertyAcandroid – Rx Kotlin：map函数无法推断返回类型
在连接到蓝牙设备的应用程序中,我使用以下函数使用RxKotlin： private fun startBluetoothPair(device: BluetoothDevice) { Observable.just(device) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .map { vRxJava2用于组合两个Maybes的习语
给定两个Maybe值,我如何将它们组合成一个可能会： >只要源Maybes中的任何一个调用onSuccess,就调用onSuccess() >只要两个源Maybes都调用onComplete(),就调用onComplete()？ (参见Scala或Vavr中的Option.orElse().) 例如,假设存在一个执行我想要的combine()方法： combine(Maybe.just(a)java – Chain Observables
我有一个对象集合,称它们为obj.他们有一个act()方法. act()方法最终会导致o上的event()observable调用onComplete. 链接这些的好方法是什么？ 也就是说,调用o.act(),等待o.event().onComplete,然后调用下一个o2.act(),依此类推,以便在集合中获得无限数量的o. 签名是这样的： public cl使用observeOn时,为什么我的RxJava Flowable不支持背压？
我正在尝试创建一个Flowable,它发出关于背压的事件以避免内存问题,同时并行运行每个转换阶段以提高效率.我创建了一个简单的测试程序来推断我的程序的不同步骤的行为以及何时发出事件而不是在不同阶段等待. 我的计划如下： public static void main(String[] args) throws ExecutionRxJava2将两个Flowable压缩成一个
我正在努力寻找任何将两个Flowable压缩成一个的RxJava2示例. 我试图修改this test以包含一些东西 Integer[] ints = new Integer[count]; Integer[] moreints = new Integer[count]; Arrays.fill(ints, 777); Arrays.fill(moreints, 777); Flowable<Integer>java – Rx运算符.忽略直到下一个被发射
在我的应用程序中,我有耗时的逻辑,可以通过多种方式启动,让我们自动或由用户手动说. // Let's describe different event sources as relays val autoStarts = PublishRelay.create<Unit>() val manualStarts = PublishRelay.create<Unit>() val syncStarts = PublishRelay.create使用RxJava(ReactiveX)运行Observable需要多长时间？
我在scala Play Framework 2.5中使用java ReactiveX(RxJava)与couchbase异步通信我想知道我的observable运行需要多长时间？我使用下面的代码定义我的observable. def get(id: String) : Observable[Profile] = { this.bucket .async() // can I have a start time here pjava – 为什么我得到NoClassDefFoundError：org / reactivestreams / Publisher
Stream.java import io.reactivex.*; public class Stream { public static void main(String args[]) { Observable.just("Howdy!").subscribe(System.out::println); } } 的build.gradle： group 'com.sakhunzai' versionjavascript – 在保持订阅的同时更改可观察流
在RxJS中,我希望即使流更改,订阅也会在流上保留.下面我使用间隔流来测试行为 //Works because foo$is unchanged let foo$= Rx.Observable.interval(1000); foo$.subscribe(x => console.log(`foo$: ${x}`)); //Doesn't work because bar$is changed let bar$= Rx.Observable.nevRxJava Observable最短执行时间
我有一个Observable(从网络获取数据). 问题是可观察的速度可能快或慢,具体取决于网络条件. 我显示进度小部件,当observable正在执行时,并在observable完成时隐藏它.当网络快速 – 进展flikers(出现和消失).我想将可观察的最小执行时间设置为1秒.我怎样才能做到这一点？ “延迟”运算Android笔记之Retrofit与RxJava的组合
依赖 implementation 'com.squareup.retrofit2:retrofit:2.5.0'implementation 'com.squareup.retrofit2:converter-gson:2.5.0'implementation 'com.squareup.retrofit2:adapter-rxjava2:2.5.0'implementation 'io.reactivex.rxjava2:rxja