将观察量数组转换为可观察量数组rxjs
是一个关于响应式编程的库，它提供了一种方便的方式来处理异步数据流。在rxjs中，观察量数组是指一个包含多个观察量的数组，而可观察量数组是指将观察量数组转换为可观察量的操作。
在rxjs中，可以使用from操作符将观察量数组转换为可观察量数组。from操作符接受一个观察量数组作为参数，并返回一个可观察量，该可观察量会依次发出数组中的每个观察量。
下面是一个示例代码，展示了如何将观察量数组转换为可观察量数组：
import { from } from 'rxjs';
const observationArray = [1, 2, 3, 4, 5];
const observableArray = from(observationArray);
observableArray.subscribe(value => {
console.log(value);
});在上面的代码中，我们首先定义了一个观察量数组observationArray，它包含了一些观察量。然后，我们使用from操作符将观察量数组转换为可观察量数组observableArray。最后，我们通过订阅可观察量数组来获取每个观察量的值，并将其打印到控制台上。
这种将观察量数组转换为可观察量数组的操作在处理异步数据流时非常有用。通过使用rxjs提供的丰富操作符和功能，我们可以更加灵活地处理和操作数据流，实现各种复杂的业务逻辑。
推荐的腾讯云相关产品：腾讯云云函数（SCF）
- 产品介绍链接地址：https://cloud.tencent.com/product/scf
相关·内容
我还在通过一些实验学习如何在rxjs中使用Angular5，我遇到了一些我很难理解的东西。
如何使用仅返回可观察对象的部分结果
我在上找到了一个可以返回500个数组项的API。
我设置了一个名为rxservice的角度服务，它使用HttpClient.get()返回如下所示的可观察值：
import { Injectable } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { of } from 'rxjs/observabl
浏览 8提问于2018-01-31得票数 0
https://rxjs-dev.firebaseapp.com/api/ajax/ajax 为什么rxjs ajax操作符返回一个Observable？我认为一个请求返回一个响应，连接就结束了。为什么它是可观察的，而不是单个响应消息？
浏览 13提问于2020-03-30得票数 1
回答已采纳
我正在使用RxJS 6.2.1，我正在尝试将一个可观察到的承诺转换为一个承诺
如果我创建一个使用订阅可以观察到的简单范围，我将得到随时间而发出的值。
import { range } from 'rxjs'
const source$ = range(0, 10);
source$
.subscribe(
x => console.log(x),
err => console.log(err),
() => console.log('complete')
)
但我怎么才能把这整件事变成承诺呢？我尝试了.toPr
浏览 0提问于2018-06-22得票数 2
回答已采纳
在我的代码中，我有一个拦截器，它处理所有出站http请求，并将令牌添加到其中。代码如下所示
intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
const promise = this.storage.get('token');
return Observable.fromPromise(promise)
.mergeMap(token => {
const clonedReq = this.addTo
浏览 0提问于2020-06-26得票数 0
有了承诺，如果你这样做：
Promise.resolve(p).then(function(){
return 5;
})
.then(function(val){
return db.find(); // promise
});
我们可以看到，promises上的then操作符可以处理任何返回值，它只是在返回结果上调用Promise.resolve()并处理它，而不管它是不是promise。
然而，使用RxJS5，我发现很难找到一个可以做类似事情的运算符。我得到了很多错误：
TypeError: You provided x where
浏览 12提问于2017-01-10得票数 0
1回答
我有以下代码来管理用户，
@Component({
selector: 'app-user',
template: `
<input [(ngModel)]="newUser"><button (click)="addNewUser()">add</button>
<div *ngFor="let user of users$ |async">
{{user}}
</div>
`
})
export class UserComponent
浏览 0提问于2019-02-06得票数 1
3回答
在我下面的Ionic 3代码摘录中，即使添加了map的rxjs操作符的所有导入，问题仍然存在。
TypeError: this.http.get(.).map不是函数
我的导入已经添加，代码如下：
import { map } from 'rxjs/operators';
import "rxjs/add/operator/map";
import "rxjs/Rx";
import { Injectable } from "@angular/core";
import { HTTP } from "@ionic-
浏览 0提问于2018-08-19得票数 3
我有一个源，它提供了一个数组。所有数组都有相同数量的元素。如何使用rxjs运算符转换源数组，如下面所述，这样我就可以轻松地进行映射了？提前感谢！
var source = Rx.Observable.from([[1, 2, 3], ["a", "b", "c"], ["do", "re", "mi"]]);
// I would like to transform to:
// [[1, "a", "do"], [2, "b", "re
浏览 1提问于2016-04-01得票数 0
回答已采纳
1回答
我是一个角度2和RXJS观测的新手，我从早上开始做一件事情，它已经完成了，但我无法了解它是如何工作的。
下面是我在test.json文件夹下的Assests/api文件：
[ {
"name" :"James T",
"address": {
"Street" : {
"data": ["Austin","I","J"]
},
"District"
浏览 0提问于2017-10-26得票数 2
回答已采纳
1回答
我一直在用房顶变换(地图，过滤器等)数据以角1。现在在@角(角2)中，显示如何使用http服务请求json的第一个例子之一使用RxJS的映射。我已经检查过RxJS有更多有用的操作符。那么，我是否应该将每个集合转换为可观测的( asObservable() )，并使用RxJS的运算符，因为它们已经包含在“角”中，并且是必需的？
浏览 0提问于2016-10-12得票数 2
回答已采纳
尝试创建一个rxjs管道，它将执行以下操作:本质上，我有一个动态数量的API调用数组。每次需要进行新的API调用时，我都会将其推送到数组中。
然后，我将该数组转换为RXJS切换映射操作符的数组。(调用的顺序并不重要，只是我需要在前一次调用结束后进行一次调用，而不是在同一时间)。
最后，我尝试在管道中扩展rxjs操作符的数组：
const obsArray = [randomQuote(), getCatFacts(4), recipeSearch('oil')]
const OperatorWrap = obsArray.map((obs) => {
return r
浏览 0提问于2021-01-11得票数 0
我经常用角4/5来做这个：
import { Http, Headers } from "@angular/http"
public listTemplates(): Observable<EmailTemplate[]> {
let url = `${this.apiUrl}/templates`
this.http.get(url).map(
response => this.parseTemplates(response.body)),
error => new ErrorObservable(er
浏览 0提问于2019-09-12得票数 0
回答已采纳
在将应用程序更新到RxJs 6(使用rxjs)时，我们面临一个问题。仍然在RxJ 5上的引用库使用ErrorObservable作为方法的返回类型。
public handleError(error: Error): ErrorObservable {
...
return Observable.throw('some error message');
}
到目前为止，ErrorObservable是RxJs：中的一种非泛型类型。
export class ErrorObservable extends Observable<any> {
...
浏览 0提问于2018-06-18得票数 4
我有一个数组，如下所示。
data = [
{
id: 1,
name: 'a',
status: true,
},
{
id: 1,
name: 'b',
status: true,
},
{
id: 1,
name: 'c',
status: false,
},
];
我通过将初始值设置为上面的数组来创建BehaviorSubject。
我希望获得数据数组，通过使用rxjs pipe
浏览 2提问于2022-02-18得票数 0
回答已采纳
我已经写下了一个组件和一个服务来显示一些对象的细节，但是当订阅并在控制台中看到它时，它显示为未定义。我已经尝试了很多，任何帮助都将不胜感激。
我已经在下面展示了所有的组件和服务，看看我在这里是否犯了任何错误。
我的组件如下：
import { Component, Input } from '@angular/core';
import { ActivatedRoute } from '@angular/router';
import { Location } from '@angular/common';
import { filter, ma
浏览 0提问于2018-04-12得票数 0
我需要从我们的API中获取大量数据点。
然而，不能一次获取所有请求，因为响应时间太长，所以我想将其分解为多个请求。响应如下所示：
{
href: www.website.com/data?skip=0&limit=150,
nextHref: www.website.com/data?skip=150&limit=150,
maxCount: 704,
skip: 0,
count: 150,
limit:150,
results: [...]
}
所以，最终我需要不断地调用nextHref，直到我们真正到达最后一个。
在每次请求之后，我希望获取结果
浏览 5提问于2021-04-19得票数 2
我已经创建了一个服务，从模拟中检索数据，如下所示：
export const PHOTOS: Photo[] = [
{
title: "title 1",
srcImage:"https:/34297040313_3436fd2556_k.jpg"
},
{
title: "title 2",
srcImage:"https://34297040313_3436fd2556_k.jpg"
}
浏览 2提问于2018-07-13得票数 1
回答已采纳
我正在构建一个Range2应用程序，它使用一个服务来收集数据。该服务确实包含以下逻辑：
/* ========== CORE COMPONENTS ========== */
import { Injectable } from '@angular/core';
import { Http, Response } from '@angular/http';
import { Observable } from 'rxjs/Observable';
import 'rxjs/Rx';
import 'rxjs/add/ope
浏览 2提问于2017-03-07得票数 7
回答已采纳
2回答
我用的是rxjs和打字本。我写了两个简单的函数。但我想rxjs已经具备了这样的功能。rxjs
export function isObservable(value: any): value is Observable<any> {
return value instanceof Observable;
}
export function createObservable<T>(value: T | Observable<T>): Observable < T > {
return isObservable(value) ? value
浏览 4提问于2017-06-08得票数 1
回答已采纳
回到学习Angular和扩展英雄之旅教程。我有一个将数据加载到BehaviorSubject中的共享数据服务。问题是，当我尝试使用*ngFor迭代数据时，我得到了“无法找到不同的支持对象”错误。从所有其他问题中，我知道它试图绑定到一个对象，而不是一个数组，但在我的生活中，我不知道为什么。或者需要将哪个对象转换为数组。
我使用的是Angular 5.0.5。有趣的是，这是与Angular 4一起工作的，但显然我在升级过程中弄坏了一些东西。
你觉得我做错了什么吗？除了所有的东西。:D lol
这是我的服务
import { Injectable, EventEmitter } from '
浏览 0提问于2017-12-07得票数 0
1回答
我正在创建一个Angular6 crud应用程序，我的数据库中有一个用户列表。当我调用getAllUsers时，我能够检索我的列表，但是它不会显示在UI中。唯一一次在表中看到一行时，是手动输入新用户时，但它不显示条目之前的数据。我做错了什么？
import { Component, OnInit } from '@angular/core';
import { UserDataService } from './user-data.service';
import { User } from './user';
@Component({
s
浏览 1提问于2018-05-17得票数 0
回答已采纳
用地图和过滤器迭代array的正确方法是什么？目前，两家公司都期望有单一的价值。但是我的Observable有数组。请告诉我正确的方法。
这是我的ts：
import { Component, OnInit } from '@angular/core';
import { Observable, of } from 'rxjs';
import { filter, map, tap} from 'rxjs/operators';
@Component({
selector: 'my-app',
templateUrl:
浏览 1提问于2021-10-07得票数 0
回答已采纳
我有一个由用户选择的项目的可观察性。所选的每一项都用作api调用的源。并且api调用的结果应该被“合并”到一个可观察对象中。
我似乎不明白的是我是如何将结果合并回来的。我尝试使用扫描操作符，但“累加器”只“增长”。
我有这个：
import {
Observable,
Subject,
of ,
from
} from 'rxjs';
import {
map,
merge,
flatMap
} from 'rxjs/operators';
function apiUri(albumId: String) {
return
浏览 7提问于2018-09-08得票数 0
回答已采纳
2回答
是否可以使用泛型将[Observable<string>, Observable<number>]类型的数组映射到[string, number]？
function example(obs: Observable<any>[]): any[] { }
期望的行为：
example(of(''), of(0)) // typeof [string, number];
我知道rxjs为combineLatest使用了ObservedValueOf<O>和函数重载，但我不想采用相同的重载方法。
浏览 5提问于2021-01-18得票数 0
回答已采纳
1回答
在RxJS中，有管道的间隔会运行吗？
这就是我的意思。假设我们有以下代码：
const arr = ["foo", "bar"];
const i = interval(500);
const toRun = i.pipe(
map(index => arr[index]),
take(arr.length)
);
toRun.subscribe(val => val);
我是否正确理解，该代码的工作原理如下：
创建了i，但是在我们订阅它之前不会运行它。
2在pipe方法的帮助下，我们创建了一个新的Observable，它构建在i之上
浏览 0提问于2020-06-17得票数 1
回答已采纳
既然我们有了“可租的”操作符，我们应该如何从另一个人创建一个Observable呢？
当我试着做：
import {Observable} from 'rxjs/Observable'
const source = Observable.from(someOtherStream)
我得到了错误Observable.from is not a function，这是有意义的，因为现在需要单独导入from。
我不想做
由于原型问题，import 'rxjs/add/observable/from'不再存在了。
我最后做的是：
import { Obser
浏览 2提问于2017-11-15得票数 2
回答已采纳
我得到了这个错误。我在试着用 import { catchError } from 'rxjs/operators' 而不是 import 'rxjs/add/operator/catch' 但是如何使用rxjs/add/operator/do和rxjs/add/operator/toPromise的instaed呢
浏览 9提问于2020-10-07得票数 3
4回答
我正在努力了解如何在角度2中使用可观测数据。我有这样的服务：
import {Injectable, EventEmitter, ViewChild} from '@angular/core';
import {Observable} from "rxjs/Observable";
import {Subject} from "rxjs/Subject";
import {BehaviorSubject} from "rxjs/Rx";
import {Availabilities} from './availabilit
浏览 2提问于2016-06-07得票数 117
回答已采纳
在调试应用程序问题的过程中，我创建了下面的简化组件。它在执行时会得到以下异常：
ingredient2service.ts:24 ["test1", "test2"]
angular2.dev.js:23093 EXCEPTION: Cannot find a differ supporting object 'test2' in [items | async in Ingredient2SearchComponent@5:12]
angular2.dev.js:23083 ORIGINAL EXCEPTION: Cannot find a di
浏览 2提问于2016-04-04得票数 1
在角度方面我有以下问题:据我理解，*ngIf指令不允许我在嵌套DOM组件上添加事件。这是代码：
模板
<div class="bf-search-field">
<input #productSearch
[(ngModel)]="term"
(ngModelChange)="search()"
(blur)="closeAutocomplete()"
(focus)="activeAutocomplete()"
浏览 1提问于2017-07-07得票数 0
回答已采纳
3回答
我正在使用 6创建RxJS，并且不清楚当操作是异步的时候如何创建观察者。
对于同步操作，逻辑很简单。在下面的示例中，来自源Observable的所有值都将传递给observer.next()，然后调用observer.complete()。
const syncOp = () => (source) =>
new rxjs.Observable(observer => {
return source.subscribe({
next: (x) => observer.next(x),
error: (e) => observ
浏览 3提问于2018-07-25得票数 2
回答已采纳
我是刚开始观察和实验克利斯朵夫·伯格多夫的的一个基本的自动完全变体。运行此代码将生成：
例外: TypeError:无法读取未定义的属性“符号(Symbol.iterator)”
在发出其余的get呼叫后，请进入ingredientservice...rawsearch。该警报还会弹出一条对象对象消息。我已经证实端点运行良好。
任何关于如何调试这方面的建议都将不胜感激。
ingredientservice.ts等待对文本字符串的更改，删除它并执行REST调用，以便从端点获得自动完成的匹配。
import {Injectable} from 'angular2/core';
im
浏览 1提问于2016-03-29得票数 9
回答已采纳
2回答
我试图从一个承诺中得到一个值，然后使用这个值来解决另一个承诺。
没有rxjs，它的工作方式如下：
Promise.resolve(1)
.then(value => Promise.resolve(value + 1))
.then(value => console.log(value))
输出：2
这是我被rxjs困住的地方
const observable = Rx.Observable.fromPromise(Promise.resolve(1))
.map(value => {
return Rx.Observable.fromPromise(P
浏览 4提问于2017-01-19得票数 1
回答已采纳
11回答
我开始使用RxJS，我不明白为什么在这个例子中我们需要使用像flatMap或concatAll这样的函数；这里的数组在哪里？
var requestStream = Rx.Observable.just('https://api.github.com/users');
var responseMetastream = requestStream
.flatMap(function(requestUrl) {
return Rx.Observable.fromPromise(jQuery.getJSON(requestUrl));
});
responseMe
浏览 4提问于2015-11-02得票数 107
回答已采纳
1回答
我有可观察的，主题等等，多亏了rxjs，
很好，我不需要异步/等待：
我的问题是，做rxjs的人是怎么做的？
他们是使用异步函数来创建他们的库，还是找到了一个更好的解决方案？
如果他们确实使用了这个函数，这就意味着，例如，我不能使用和rxjs，对吗？
浏览 0提问于2019-09-04得票数 0
回答已采纳
2回答
我正在学习角和RxJS操作符。我正在使用Hearthstone来训练它。我做错什么了？我想过滤流只返回“萨满”牌。我知道，阿皮给了我机会，让我在课堂上得到卡片，但我只想培训RxJS，所以我正在考虑这个问题。我的ts组件：
cards: Card[];
ngOnInit() {
this.cardsService.getCards().pipe(
filter((el: any) => el.playerClass === 'Shaman')
).subscribe(res =>
this.cards = res);
浏览 0提问于2019-02-19得票数 2
回答已采纳
我正在尝试使用bindNodeCallback和fs readdir、stat读取文件。
这是我的密码：
import { readdir, stat, Stats } from "fs";
import { bindNodeCallback, Observable, of } from "rxjs";
import { catchError, filter, flatMap, map, mergeMap, switchMap, tap } from 'rxjs/operators';
const readDirBindCallback: (p
浏览 0提问于2020-05-11得票数 1
回答已采纳
我一直试图用mergeMap来解决这个问题，但我不认为它是正确的。
我有一个方法getNumbers()，它的http请求返回数字列表
我有一个带有另一个方法getData()的服务，其中包含一个http请求，该请求获取给定数字的数据(可观察到的)
我需要运行第一个请求，然后对结果中的每个数字运行第二个请求。我希望所有这些都是并行的，而不是等待回应。在每一个后面运行的逻辑完全相同。
下面是我目前使用rxjs的不带的解决方案
this.getNumbers().subscribe((nums: number[]) => {
nums.forEach((num: number) =&
浏览 3提问于2021-08-23得票数 1
回答已采纳
尝试学习Angular和RxJS，我和我对数据服务应该返回什么感到有点困惑。一个对象序列还是一个对象数组？最好的做法是什么？
import { from, of } from 'rxjs';
import {map, toArray} from 'rxjs/operators';
const items = [
{id: 1, name: "foo"},
{id: 2, name: "bar"}
];
// "Standard" map behaviour going throuch each
浏览 2提问于2019-06-13得票数 1
回答已采纳
嘿，我是下一个我的角度，我和一个团队一起工作，他们使用非常老的角度，我试图升级很多东西，我以前的rxjs是在5.4版本，现在我升级到6.5地图，捕捉和抛出不再接受，我读了一些文章也是如何转换它们，但仍然不清楚，因为大多数文章没有解释如何得到json()的回应。
下面是我以前的rxjs5.4语法
import { Observable } from "rxjs/Observable";
import "rxjs/add/operator/catch";
import "rxjs/add/operator/map";
import "rxjs
浏览 0提问于2019-05-23得票数 0
我正在试着写一个可以把数字转换成字母的代码。例如，1将是“A”，2将是“B”，3将是“C”，以此类推。我正在考虑写26个if语句。我想知道有没有更好的方法...
谢谢!
浏览 1提问于2012-02-13得票数 6
我知道rxjs和definition的定义和职责，但是我想知道:当我在我的项目中使用rxjs时，我能抛出lodash吗？因为rxjs可以同步和异步地工作(异步和同步数据)。我认为这可以作为房客的另一种选择。我说的对吗？
浏览 1提问于2018-12-30得票数 7
回答已采纳
我有一个简单的问题。RxJS v5使用大理石图进行测试(示例)。是否可以在RxJS v4中使用相同的技术?如果可以，如何使用？
浏览 0提问于2016-03-03得票数 0
2回答
因此，当我试图循环遍历每个api接收的数据时，我会得到以下错误：
无法找到“对象”类型的不同支持对象“对象对象”。>NgFor只支持绑定到诸如数组之类的Iterable。
这里是我的组件，在这里我尝试循环遍历它，(main.component.html)：
<app-editform [toDo$]="todo" *ngFor="let todo of cs.$todos"></app-editform>
下面是main.component.ts的构造函数
import {ConfigService} from '.
浏览 1提问于2019-01-16得票数 0
回答已采纳
我正在将异步方法应用于由observalbe发出的每个值。我希望此异步方法仅在前一个值的异步方法完成后才应用于下一个发出的值。
下面是一个简短的示例：
import { of } from "rxjs";
const timeout = (ms) => {
return new Promise(resolve => setTimeout(resolve, ms));
};
of(1, 2, 3).subscribe(async (val) => {
console.log(`starting to use ${val}`);
await t
浏览 2提问于2021-04-22得票数 1
1回答
我有一个angular2程序，在该程序中，当单击另一个组件时，我希望更新组件的数据。我提供了一个服务，其中我有两种方法，一种用于更新数据，另一种用于获取数据。
我的服务如下
import { Injectable } from '@angular/core';
import { Subject } from 'rxjs/Subject';
import { Observable } from 'rxjs/Observable';
import { BehaviorSubject } from 'rxjs/BehaviorSubject&#
浏览 2提问于2017-09-11得票数 1
4回答
我有一个数组，我需要使用这个数组的非常单一的数据集发出单个请求。我发现难以解决的问题是如何安排呼叫。意味着，只有当一个请求完成时，下一个请求才会开始。我正在寻找一个RxJs队列，但我不能简单地找到解决方案。 示例： function makeRequest(body): Observable<any> {
return someAsyncRequest(body);
}
array.forEach((entry) => {
makeRequest(entry);
});
// This is just an example how the setup is
浏览 29提问于2019-11-20得票数 2
回答已采纳
1回答
我使用RxJS，我需要返回一个可以观察到的类型im --我的方法：Observable<MyStuff>
当我想抛出一个错误时，我使用：
import { throwError } from "rxjs";
/// ... stuff
return throwError('Error stuff invalid');
throwError返回一个Observable<never>，它与Observable<MyStuff>的类型不同
我想用这个类型抛出一个错误：Observable<MyStuff>，如果可能的话，
浏览 0提问于2018-11-30得票数 1
回答已采纳
2回答
我的rxjs流中有一个map操作。
streaming.map((data) => {
//example async call
methodCall.then((response) => {
return data.test
})
})
.filter((value) => ...);
问题是filter是在data.test自然返回之前调用的。因此，我尝试将其转换为switchMap并返回一个可观察对象
streaming.switchMap((data) => {
return Observable.create((observer) =&
浏览 0提问于2017-01-24得票数 4
回答已采纳
拿出角英雄，并增加一列的评级。评级包含好的、非常好的、差的等价值。
试图利用RxJS、filter操作符来实现这一点。当查看示例2时，它似乎是我想要的
// RxJS v6+
import { from } from 'rxjs';
import { filter } from 'rxjs/operators';
//emit ({name: 'Joe', age: 31}, {name: 'Bob', age:25})
const source = from([
{ name: 'Joe', age: 31
浏览 2提问于2020-03-08得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
