Observable - Subscribe未收到预期值
Observable是一种在响应式编程中常用的概念，它代表了一个可观察的数据流。在Observable中，数据可以被订阅者（Subscribe）观察，并在数据发生变化时通知订阅者。
Observable的分类：
- 冷Observable：在订阅之后才开始发送数据的Observable。
- 热Observable：在创建之后就开始发送数据的Observable。
Observable的优势：
- 异步处理：Observable可以处理异步操作，例如网络请求或者定时任务。
- 数据流处理：Observable可以对数据流进行处理和转换，例如过滤、映射、合并等操作。
- 错误处理：Observable可以处理错误，通过错误处理操作符可以捕获和处理错误。
- 取消订阅：订阅者可以随时取消对Observable的订阅，避免资源的浪费。
Observable的应用场景：
- 前端开发：在前端开发中，Observable常用于处理用户交互、异步请求和数据流处理等场景。
- 后端开发：在后端开发中，Observable可以用于处理并发请求、数据流处理和事件驱动等场景。
- 移动开发：在移动开发中，Observable可以用于处理用户输入、网络请求和数据流处理等场景。
- 人工智能：在人工智能领域，Observable可以用于处理大规模数据集的处理和分析。
腾讯云相关产品： 腾讯云提供了一系列与Observable相关的产品和服务，例如：
- 腾讯云函数（云原生）：腾讯云函数是一种事件驱动的计算服务，可以将Observable与函数计算相结合，实现异步处理和事件驱动的应用。 产品介绍链接：https://cloud.tencent.com/product/scf
- 腾讯云消息队列 CMQ：腾讯云消息队列 CMQ是一种高可靠、高可用的消息队列服务，可以与Observable结合使用，实现消息的发布和订阅。 产品介绍链接：https://cloud.tencent.com/product/cmq
- 腾讯云数据库 CDB：腾讯云数据库 CDB是一种高性能、可扩展的云数据库服务，可以与Observable结合使用，实现数据的观察和处理。 产品介绍链接：https://cloud.tencent.com/product/cdb
通过使用腾讯云的相关产品，开发者可以更好地利用Observable的特性，实现各种应用场景下的数据处理和观察。
相关·内容
我有一个问题，所有的角度9的项目，我正在工作。在运行ng serve之后，当我尝试在本地浏览器中加载它们中的任何一个时，我只得到一个从未停止加载的白色页面。如果我让它运行足够长的时间，浏览器最终会告诉我有一个长时间运行的脚本。
无论是在编译时还是在运行时，我都不会在角cli中收到任何错误或警告。浏览器也不报告任何错误。
如果我将项目移到另一台计算机上，它们可以正常工作，不会出现任何问题。
当我做一个项目时，这个问题突然出现了。我尝试过删除每个非必需的文件/文件夹(比如、node_modules、)并重新初始化它们，但这似乎没有帮助。
如果我暂停脚本的执行，它主要停留在_updateTaskCo
浏览 2提问于2020-07-09得票数 0
在我的代码中，我使用share()创建了一个热的observable，如果我没有完成observable，或者使用setTimeout将其设为异步，则只执行第一个订阅，之后的任何附加订阅都不会执行。这是一种预期的行为吗？
const c=Rx.Observable.create((obs)=>{
obs.next(1)
// add this will work
// setTimeout(()=>obs.next(1),1000)
// add this will work too
// obs.complete()
}).share()
// excuted
c.subscr
浏览 2提问于2018-06-07得票数 0
2回答
组合多个/冗余ngrx语句
、、、、
我正在使用ngrx/angular4 4+开发一个应用程序。这里正在开发的一种设计模式看起来非常冗余，这与您如何订阅Store减缩器有关。
在组件中，以下情况并不少见：
HOFDetails$:Observable<any>;
HOFDetails$SUB:ISubscription;
HOFMobile$:Observable<any>;
HOFMobile$SUB:ISubscription;
HOFMobile:any;
HOFHome$:Observable<any>;
HOFHome$SUB:ISubscription;
HOFHome:any;
浏览 1提问于2018-06-26得票数 0
我正在尝试从一个API端点获取课程列表，并从另一个端点获取与每个课程相关联的作业。我正在使用concatMap来合并观察值，但它并没有像我预期的那样工作。它不是发出每个课程的作业，而是发出可观察的对象。 function getCourses() {
return fromFetch("https://canvas.instructure.com/api/v1/courses", {
method: "GET",
headers: {
"Content-Type": "application/json&#
浏览 30提问于2021-10-16得票数 1
回答已采纳
我有一个包含以下内容的服务
@Injectable({
providedIn: 'root'
})
export class MyService {
private mySubject = new BehaviorSubject({});
public currentData = this.mySubject.asObservable();
updateData(data: any) {
this.mySubject.next(data);
}
}
我有一个订阅了Observable的组件，包含以下内容：
export class MyCompo
浏览 0提问于2018-09-26得票数 0
2回答
我有以下代码：
final Observable<String> a = Observable.just("a1", "a2");
final Observable<String> b = Observable.just("b1");
final Observable<String> c = Observable.combineLatest(a, b, (first, second) -> first + second);
c.subscribe(res ->
浏览 0提问于2018-02-20得票数 2
回答已采纳
1回答
如果还没有加载活动成员，那么我有一个保护程序来阻止用户进入路由。有时，主动成员被缓存，守卫立即返回true。当可观察到的人立即发出真信号时，守卫就不起作用了，好像它从来没有收到过发出的“真”。如果我添加了一个settimeout，那么所有的事情都会像预期的那样正常工作。为什么警卫不像我期望的那样工作呢？
Works
canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): Observable<boolean> {
this.store.select(getActiveMember).pi
浏览 0提问于2018-04-17得票数 0
回答已采纳
我正在做一个有角度的项目，我不完全理解为什么这个代码段不能像预期的那样工作：
const httpObs = Rx.Observable.of("")
.do(() => console.log("trigger http call")) //only triggered once
.publishReplay(1).refCount();
let observable = Rx.Observable.timer(0,1000)
.do((e) => console.log("new event: " + e))
.
浏览 0提问于2018-01-26得票数 2
2回答
我有一个Observable，它可以在订阅之后的一段时间内发出事件(例如，来自Retrofit的Observable )。对此Observable的订阅严格为View-related，因此当View被销毁时，我将从Observable取消订阅。我想在doOnNext中执行一些操作，即使我取消订阅Subscription。
示例代码：
final Observable<String> observable = ...; // will emit an event in some time in future
final Subscription subscription =
浏览 2提问于2016-03-29得票数 0
回答已采纳
1回答
我有一个可观察到的数组，并希望传递给Rx.Observable.zip。我试过了，但根本没有订阅。
代码片段(仅举个例子)：
const sourceOne = Rx.Observable.of('Hello');
const sourceTwo = Rx.Observable.of('World!');
const sourceThree = Rx.Observable.of('Goodbye');
const sourceFour = Rx.Observable.of('World!');
const arr$ = [sour
浏览 20提问于2017-01-13得票数 11
回答已采纳
通常，当您订阅某个值的更改时，您也会对知道初始值感兴趣。我希望我的IObservable缓存最新(或初始)值，并在订阅时推送该值。
在使用普通事件时，我通常会得到如下代码
x.SomeEvent += SomeEventHandler;
SomeEventHandler(x, EventArgs.Empty);
使用IObservable时，我希望用一些可以推送初始值的东西来包装事件。如果我有多个订阅者，他们应该在订阅时收到最新的值，我有一些代码，如果我在创建IObservable之后立即订阅，但如果事件在订阅之前触发，则不会正常工作：
class Program
{
static v
浏览 1提问于2010-11-13得票数 5
回答已采纳
2回答
在Kotlin的zip方法中，作为参数使用的可观测值的数量似乎是有限的。如果这是正确的，最好的选择是什么？
例如，当我使用9个参数时，它就像预期的那样工作。当我添加第10个参数时，我收到错误无法推断该参数的类型。请显式指定它为
Observable.zip(
//TODO: parameterize exchange symbols based on pair
methodOne() as Observable<Any>),
methodTwo() as Observable<Any>),
浏览 0提问于2018-06-19得票数 0
回答已采纳
2回答
我需要从我的状态中获取ID作为单独的Observable，将它们组合到一个Observable中并对其执行subscribe()。我需要我的订阅者最终会得到一个解析的Observable结果数组。
此外，我需要保持此订阅打开，因此，如果我的内部Observable之一的变化，我的订阅者将被通知。
这是我的代码：
getTransactionsByIDs(transactionsIDs){
return Observable.of(transactionIDs
.map(transactionID => this.getTransactionByID(transactionID)));
浏览 0提问于2018-01-17得票数 12
回答已采纳
我有一个条件，返回一个可以观察到的条件，如下所示：
app.component.ts
import { Observable } from "rxjs";
export class ProductComponent implements OnInit
ProductListLength: Number;
isProductListEmpty: Observable<boolean>;
}
ngOnInit(): void {
if(this.ProductListLen
浏览 3提问于2021-09-27得票数 1
回答已采纳
我正在调用一个API端点，并收到一个返回的错误消息，但在使用console.log时无法查看该错误，因为我收到了下面的错误消息。有没有其他方法可以得到这个错误？
错误
TypeError: Cannot read property 'length' of null
at http.js:109
at Array.forEach (<anonymous>)
at HttpHeaders.lazyInit (http.js:103)
at HttpHeaders.init (http.js:251)
at HttpHeaders.
浏览 65提问于2018-05-07得票数 6
为什么下面的RxSwift代码没有编译，我如何解决这个问题？这一行observer.onNext("test123")就是问题所在。
final class TestA<String>: ObservableType {
typealias E = String
private let _observable: Observable<String>
init() {
_observable = Observable<String>.create { observer -> Disposabl
浏览 0提问于2018-11-04得票数 1
回答已采纳
1回答
我试着用.subscribe()让可观察到的东西变得火热。
与大多数语言不同，Python的rx v3.0使用管道命令来链接操作-例如replay()、ref_count()或publish() -而不是通常的‘’。链条。以下是指向管道命令的链接：
我非常确定这个问题与我给replay()的第一个参数有关：lambda x: x。
import rx.subject
from rx import operators as op
stream = rx.subject.BehaviorSubject(0)
replayable_observable = stream.pipe(op.repl
浏览 2提问于2019-08-22得票数 2
我想要创建一个Observable链，它将能够在下一个expand发生之前将http数据添加到每个expand中，但我不知道怎么做。
实际测试：
Observable.of('')
.expand(n => n.length < 15 ? Observable.of(n + 'e') : Observable.empty())
.mergeMap(n => Observable.of(n + 'm'))
.subscribe(v => console.log(v)
浏览 2提问于2017-08-15得票数 2
回答已采纳
我跟随英雄的角度巡回演出，并以相同的方式构造了(我认为)我的代码版本，但没有收到我期望的行为。
我的服务
import { Injectable } from '@angular/core';
import { PORTS } from './mock-ports'
import { Port } from './port'
import { Observable, of } from 'rxjs';
import { HttpClient, HttpHeaders } from '@angular/common/http
浏览 0提问于2020-04-30得票数 0
回答已采纳
2回答
我有一段代码要定期执行，直到所有订阅者都没有订阅为止。
// This function shall be called *once* per tick,
// no matter the quantity of subscriber.
function doSomething(val) {
console.log("doing something");
return val;
}
observable = Rx.Observable.timer(0, 1000).map(val => doSomething(val));
const first =
浏览 0提问于2018-05-15得票数 5
回答已采纳
我正在使用一个使用BehaviorSubject的shareDataService，如下所示。我的问题是，每次调用服务的next()方法时，任何其他组件中的侦听器订阅都会被多次调用，看起来它多次收到相同的消息。这是预期的行为吗？如何预防？
这项服务是单身人士。我不会多次调用changeMessage
@Injectable()
export class ShareDataService {
messageSource = new BehaviorSubject(someData);
currentMessage: Observable = this.messageSource
浏览 0提问于2018-07-23得票数 7
回答已采纳
我很难使用BehaviorSubject (通过RxRelay.BehaviorRelay)存储来自连续Observable的最新排放。
所谓“连续”，我指的是源Observable被设计为每当它的底层数据集发生变化时就会发出数据。
BehaviorSubject被订阅到源Observable。
看来，一旦我订阅了BehaviorSubject，我似乎只收到从源Observable发送到BehaviorSubject的第一个值。源Observable似乎不再不断地发出，实际上，不再发出更多的项。
因此，这里有一个有点做作的例子：
//A Singleton
public class DataM
浏览 1提问于2016-11-08得票数 2
回答已采纳
处理从Observable#subscribe(Consumer)返回的Observable#subscribe(Consumer)是否保证Consumer不会收到对accept的进一步调用？若非如此，我又如何获得这样的保证呢？
如果存在差异，则会观察到Observable，并将Disposable配置在同一个单线程Scheduler中。
浏览 0提问于2018-05-17得票数 0
回答已采纳
获取错误"Clicked NaN times“执行下面的Rxjs代码的正确方式是什么？
import { Component, ViewChild, ElementRef } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/fromEvent';
import 'rxjs/add/operator/scan';
import 'rxjs/add/operator/throt
浏览 0提问于2017-07-05得票数 2
现在我正试着把这件事想清楚：
import {Observable} from "rxjs";
import {delay, first, takeUntil, tap, withLatestFrom} from "rxjs/operators";
const obs1 = new Observable(s => s.next(1)).pipe(delay(1000));
const obs2 = new Observable(s => s.next(2));
obs2
.pipe(
withLatestFrom(obs1),
浏览 0提问于2019-09-09得票数 2
回答已采纳
1回答
observable.subscribe(onNext: { _ in
somePrivateFunction()
}) 当observable收到一个事件时，RxSwift用什么方法来测试somePrivateFunction是否被实际调用？因为订阅和函数在同一个类中，所以我不能模拟它。
浏览 18提问于2020-04-13得票数 0
2回答
没有值的超时可观察订阅
、、、、
我订阅了一个来自Firebase的可观察的返回值。如果连接有问题，我希望订阅超时。正确的做法是什么？我尝试了以下操作，但这是在收到最后一个值后20秒的超时时间：
let chatSubscription = this.getChats().timeoutWith(20000, Observable.throw(new Error('timeout'))).subscribe(chats => { ... });
//编辑: getChats()
getChats() {
return Observable.create(observer => {
浏览 2提问于2017-10-03得票数 1
回答已采纳
7回答
我创建了自己的Observable并订阅了两个函数。我希望对序列中的每个元素都执行这两个函数，但只有最后一个是。
let observer = null
const notificationArrayStream = Rx.Observable.create(function (obs) {
observer = obs;
return () => {}
})
function trigger(something) {
observer.next(something)
}
notificationArrayStream.subscribe((x) => consol
浏览 6提问于2016-04-23得票数 60
回答已采纳
我需要过滤一个对象列表，并从一个string[]成员创建一个不同的可观察流。Typescript 2.9.2 interface Product2 {
id: number;
categories: string[];
}
const products: Product2[] = [
{id: 1, categories: ['abc', 'def']},
{id: 2, categories: ['def', 'xyz']}
];
const products$: Observable<Produc
浏览 22提问于2019-04-12得票数 0
回答已采纳
1回答
我从订阅数据中可以观察到，如果我没有设置setTimeout，我就无法获得对象的childnode。目前我设定了超时时间。而是寻找正确的角度。
这是我的代码：
ngOnInit() {
this.store.appData.subscribe(value => {
this.appData = value;
setTimeout(() => this.setLocales(), 1000); //requires this
} );
}
setLocales(){
c
浏览 0提问于2018-04-30得票数 0
回答已采纳
我看到了一些意想不到的结果，当使用combineLatest在一组寒冷的可观测数据。它从所有可观测到的所有元素中发出最新的，而不是将第一个(n-1)观测值中的最新数据与第n个可观测到的每个元素相结合。
let observable = ReplaySubject<Int>.createUnbounded()
let observable2 = ReplaySubject<String>.createUnbounded()
observable.onNext(1)
observable.onNext(2)
observable.onNext(3)
observable.
浏览 2提问于2020-11-02得票数 2
回答已采纳
2回答
我将模拟包装到可观察性中的http调用。我最初的想法是简单地使用类似于Promise.resolve的Observable.of，但它似乎没有像我预期的那样工作：
Rx.Observable.of('of1').subscribe(e => console.log(e));
console.log('of2');
Rx.Observable.from(Promise.resolve('from1')).subscribe(e => console.log(e));
console.log('from2');
浏览 59提问于2016-11-10得票数 5
回答已采纳
1回答
我有两个角(1.6.4)组件和一个服务。该服务创建了两个这样的可观察对象(Coffeescript).
// In service constructor
@observable = Rx.Observable.create (source) =>
source.next(123)
@observable2 = Rx.Observable.create (source) =>
@observer = source
$timeout =>
@observer.next(345)
, 1000
在我的控制器里我有这些线
//Component
浏览 5提问于2017-07-18得票数 0
回答已采纳
我在摆弄rx运算符，我很好奇为什么just(null).repeat()不能作为任何内置运算符的参数：
Observable.interval(1, TimeUnit.SECONDS)
.sample(Observable.just(null).repeat())
.subscribe(System.out::println);
我本以为这会打印0 1 2 3 ...，但它就挂了。我想这是因为repeat占用了默认的Scheduler，然而，如果你交换了interval和just-repeat的角色，那么它就会像预期的那样工作，每秒打印一次null：
Observable.ju
浏览 1提问于2017-02-16得票数 1
回答已采纳
我有一个简单的用例：
收到事件通知
对事件执行一些操作
在x间隔后打印内容
如何在一个Rx管道中完成上述步骤？
如下所示：
void Main()
{
var observable = Observable.Interval(TimeSpan.FromSeconds(1));
// Receive event and call Foo()
observable.Subscribe(x=>Foo());
// After 1 minute, I want to print the result of count
// How d
浏览 4提问于2015-07-04得票数 0
回答已采纳
发现在主题上调用onNext事件后10-20ms内订阅序列化的PublishSubject时，新订阅者的onNext不会被调用。 在下面的代码片段中，observe1的值被指定为" 2000“，并且在对值为1998 2的主题调用onNext()后调用subscribeToSubject()；我们可以看到，如果间隔是10ms，新订阅者将错过由主题激发的值2000；而如果间隔是50ms或更长，则新订阅者似乎收到了预期值；这是预期的行为吗？ 此行为在RxJava 2.1.0上可见；似乎是某种竞争条件 public class PublishSubjectTest {
privat
浏览 5提问于2019-02-20得票数 0
回答已采纳
为什么在subject.onNext(o)中调用doOnSubscribe没有任何效果，但是调用subject.onComplete()会导致流终止！？
final PublishSubject<Integer> subject = PublishSubject.create();
final Observable<Integer> observable = subject.doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(
浏览 3提问于2017-04-06得票数 1
回答已采纳
3回答
如何正确处理下一个函数中的错误？
this.userService.getUser(uid)
.pipe(
catchError(err => {
this.router.navigate(['/sign-up']);
})
)
.subscribe(user => {
if (user) {
this.store.dispatc
浏览 4提问于2020-04-04得票数 0
回答已采纳
我有一个Observable发射项目，我想合并到它的特殊项目作为“时间滴答”，因为最后一个项目已经收到。
我试着玩timeout+onErrorXXX或interval的游戏，但没能让它像预期的那样工作。
import io.reactivex.Observable;
import io.reactivex.functions.Function;
import org.apache.log4j.Logger;
import org.junit.Test;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.Tim
浏览 1提问于2018-02-06得票数 0
我有一个可以观察到的物体。当我订阅时，其他属性(自定义为可观察的)已经添加到对象中。
const obj = {
a: 'some text'
};
const b$ = of('BBB').pipe(delay(1000));
const c$ = of('CCC');
const obj$ = of(obj).pipe(delay(100));
const res$ = obj$.pipe(
map(obj => Object.assign({
b: b$,
c: c$
}, obj))
)
const
浏览 1提问于2018-12-19得票数 1
回答已采纳
从今天早上开始，我就一直在学习观察者parttern，但似乎无法找到如何使用内置接口来实现它。我已经看过一些例子了，但还没有找到任何简单的例子。
到目前为止，这是我受启发的代码：
class ObservableClass : IObservable<bool>, IDisposable
{
public bool observableBool;
public List<IObserver<bool>> observers;
public ObservableClass()
{
this.observable
浏览 1提问于2019-12-14得票数 0
我不明白为什么rxjs共享操作符不适用于setTimeout()。
我在试着理解这个。在本例中，“共享订阅”的概念似乎不像预期的那样起作用。
const observable1 = Observable.create(observer => {
observer.next(`I am alive.`);
setTimeout(() => {
observer.next(`I am alive again.`);
}, 1000);
}).pipe(share());
observable1.subscribe(x => console.log(x));
浏览 6提问于2019-10-11得票数 3
回答已采纳
我有一个数据服务，它从服务器获取数据，并发出多个请求，然后返回一个可观察到的数组。我要测试数据。
我尝试做的是在我发送的数组中，其中包含两个可观察到的，我不知道这是否是测试数据的正确方法。
但是测试失败了，特别是异步测试块中的最后三个测试。
重要:我想测试的是，当将charId设置为falsy，将comicsId设置为falsy，调用t该方法，订阅可观察的方法返回时，在您模拟http之后，您将得到一个包含两个预期响应的数组。如果charId是真实的，那么4种预期的响应也是一样的。当comicsId是真实的时，6个预期的响应也是一样的
//获取数据的服务
getChar(): Observabl
浏览 1提问于2017-11-01得票数 8
我使用ormlite并将数据库数据转换为rx可观察值。
public static <T> Observable<T> createObservable(@NonNull Observable<T> observable) {
return observable.subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread());
}
public Observable<List<Country>> getCountriesObserv
浏览 8提问于2017-07-19得票数 2
回答已采纳
我用toString()创建了一个Foobar类，它工作得很好，除非Foobar是从rest调用返回的。下面是代码和输出。FOOBAR-1按预期工作，但FOOBAR-2返回的不是字符串，而是对象。为什么？FOOBAR-3按预期返回，因此它知道这是一个Foobar。
app.component.ts
import { HttpClient } from '@angular/common/http';
import { Component, ViewChild } from '@angular/core';
import { Foobar } from '.
浏览 0提问于2020-11-17得票数 0
我正在使用TypeScript的RXJS，偶然发现了一个我无法解释的问题。我有一个发出多个字符串的observable。然后我想对它应用switchMap，它应该在每个字符串前面加上"a“：
var o = Observable.create((observer) => {
observer.next("hi")
observer.next("bla")
})
o.switchMap(str => "a" + str).subscribe(str => console.log(str))
我的预期输出：
浏览 14提问于2017-03-14得票数 14
回答已采纳
我希望下面两段代码是等价的。默认情况下，重复使用currentThread调度程序。如果我们将其更改为一个immediate调度程序：
Rx.Observable.fromArray([1,2,3,4,5]).flatMap(a => {
return Rx.Observable.repeat(a, 3, Rx.Scheduler.immediate)
})
.subscribe(r => console.log(r));
上面的代码产生了预期的结果：1, 1, 1, 2, 2, 2, ...。但是下面的代码没有，并产生了一个混合值序列：
Rx.Observable.fromA
浏览 3提问于2015-06-23得票数 2
回答已采纳
我正在尝试制作一个验证器，以检查电子邮件地址是否已经存在，并且和往常一样，我们不希望服务器在用户仍在输入电子邮件地址时受到请求的锤击。
目前，代码如下所示
return Observable.timer(1000).switchMap(() => {
return this.userService.emailExists(control.value)
.mapTo(exist => Observable.of({ "emailExists": exist }))
.catch(err => Observable.o
浏览 4提问于2017-09-16得票数 0
回答已采纳
我想同时调用两个when服务，并在两者都完成后处理响应。我使用Rx的Observable.FromAsyncPattern方法调用the服务。同时订阅多个IObservables的正确方法是什么？
我试过使用Zip，但它似乎没有同时启动，只在收到第一个结果之后才启动第二个。
编辑：，这是Zip的一个演示，或者其他一些没有解决我问题的解决方案--
class Program
{
static void Main(string[] args)
{
var observable1 = Observable.Create<int>(i =>
浏览 13提问于2011-07-12得票数 1
回答已采纳
我把可观测到的东西推到这样的阵列里.
var tasks$ = [];
tasks$.push(Observable.timer(1000));
tasks$.push(Observable.timer(3000));
tasks$.push(Observable.timer(10000));
我想要一个可观察的，当所有的任务都完成的时候发出的声音。请记住，在实践中，任务$并没有已知的可观察值。
我尝试过Observable.zip(tasks$).subscribe()，但在只有一个任务的情况下，这似乎失败了，并使我相信ZIP需要偶数的元素才能按我预期的方式工作。
我尝试过Observabl
浏览 5提问于2017-01-19得票数 85
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
