用不带内部订阅的外部数组展平嵌套观测值(RxJS)
用不带内部订阅的外部数组展平嵌套观测值是指使用RxJS库中的操作符来展平嵌套的观测值，并且在展平过程中不会产生内部订阅。
RxJS是一个用于响应式编程的库，它提供了丰富的操作符来处理数据流。展平嵌套观测值是RxJS中常见的操作之一，它可以将嵌套的观测值转换为扁平的观测值，方便后续的处理。
展平嵌套观测值的操作符有多种，常用的有concatAll、mergeAll、switchAll和exhaust。它们的区别在于对于多个内部观测值的处理方式不同。
- concatAll：按顺序依次处理每个内部观测值，等待前一个内部观测值完成后再处理下一个内部观测值。
- mergeAll：同时处理所有内部观测值，内部观测值之间的顺序不确定。
- switchAll：只处理最新的内部观测值，忽略之前的内部观测值。
- exhaust：只处理第一个内部观测值，忽略之后的内部观测值，直到第一个内部观测值完成后才会处理下一个内部观测值。
展平嵌套观测值的应用场景包括处理嵌套的异步操作、处理嵌套的数据结构等。
腾讯云提供了云原生应用开发平台Tencent Cloud Native，它提供了一系列的云原生产品和服务，包括云原生应用开发框架、容器服务、微服务框架等，可以帮助开发者快速构建和部署云原生应用。
相关产品和产品介绍链接地址：
- Tencent Cloud Native产品介绍：https://cloud.tencent.com/product/tke
- Tencent Cloud Native容器服务：https://cloud.tencent.com/product/tke
- Tencent Cloud Native微服务框架：https://cloud.tencent.com/product/tse
请注意，以上答案仅供参考，具体的产品选择和推荐应根据实际需求和情况进行评估。
相关·内容
1回答
嗨，我想知道是否有人可以帮助我过滤一个对象数组。当我执行以下操作时，它将返回一个数组数组，而不是执行特定显示所需的对象数组
public ngOnInit(): void {
this.checkboxItems.map(x =>
x.formControl.valueChanges.subscribe((state: boolean) => {
const filterOption = Object.keys(x.formControl.parent.controls).find(key => x.formControl.parent.controls[key
浏览 2提问于2021-02-22得票数 0
我正在尝试理解combineAll操作符是如何工作的。我使用中的以下示例
import { take, map, combineAll } from 'rxjs/operators';
import { interval } from 'rxjs';
const source$ = interval(1000).pipe(take(2));
const example$ = source$.pipe(
map(val =>
interval(1000).pipe(
map(i => `Result (${val}): ${
浏览 1提问于2017-07-19得票数 12
回答已采纳
2回答
我想从我的名为Events的消防站集合中获得我拥有的eventID的值。我能够在我的应用程序中获取和显示我的所有事件，但是我需要这个eventID来完成其他功能。
我不熟悉TS和working，也不明白为什么这不管用
当我在auth函数中记录我的userid变量时，它可以很好地工作并检索值，但是如果在函数之外这样做，它会给出未定义的值。
另外，当我记录为存储来自火药库的信息而创建的整个eventList变量时，它会记录所有信息，但是如果我试图检索任何信息，例如，this.eventList.eventID或this.eventList.title，它将记录未定义的日志。
我做错了什么？
这是我
浏览 3提问于2021-11-21得票数 1
回答已采纳
我有一个来自angular的situation to make a nested rest api call。我必须对前面的调用进行one call after another call based on the result，如下所示
OuterLoop: while (1) {
getHttpResponse1().subscribe((value1) => {
if (value1 == 'A') {
InnerLoop: while (1) {
getHttpResponse2().subscribe((
浏览 7提问于2021-11-22得票数 0
1回答
我正在使用大理石图来显示两个不同的可观测数据的输出。第一种是使用开关映射，它将管道连接到另一个开关映射中。第二个可观测到的装置在同一个管道中有两个开关图。
这是两个大理石流：
第一种方法是在内部管道内部使用开关映射。
第二种方法是使用单管内部的开关映射。
他们为什么会有不同的结果？
浏览 0提问于2019-09-12得票数 1
回答已采纳
我对elastic search比较陌生，对于访问list中的元素中的元素有一个问题。结构如下：
{
'TestA':'1',
'TestB':{
'TestC':'2',
'TestD':[
{
'TestE':'3',
'TestF':'4'
},
{
浏览 0提问于2018-10-23得票数 1
我尝试使用合并运算符来组合四个不同的可观测对象，它们都发出相同类型的T。我想合并这四个可观测对象，这样我就有了一个发出T[]的可观测对象，然后我可以映射结果列表。
然而，我注意到，当订阅合并的可观察对象时，只会发出列表中第一个可观察对象的结果。为什么会这样呢？
我认为这可能与正在使用的map有关，但如果合并的可观察对象的结果是作为单个流发出的，这不应该是一个问题，不是吗？
this._signalRService.categoryGroupChangeSignal.pipe(
takeUntil(this.destroyObservables),
swi
浏览 0提问于2020-03-11得票数 0
1回答
我有如下的映射：
"profile": {
"properties": {
"educations": {
"properties": {
"university": {
"type": "string"
},
&#
浏览 1提问于2013-12-18得票数 2
3回答
我需要了解内部可观察性是否没有成功完成(每个人都没有订阅)，并在这种情况下发出一个值。一种defaultIfEmpty，但不起作用。
有一个触发(间隔)。
有一个复杂的逻辑可以消耗大量的时间(计时器)。
当触发器再次被触发并导致复杂逻辑(switchMap)的取消时，我希望在流中得到有关它的通知(以发出一个值)。
这里是一个stackblitz.com示例，
代码
import {Component, OnDestroy, OnInit} from '@angular/core';
import * as rxjs from 'rxjs';
浏览 3提问于2020-04-25得票数 2
回答已采纳
我有rxjs嵌套的可观测值，它们工作得很好。
this.service.save(body).subscribe(
() => {
this.dialog.confirmDialog({
title: '',
message: 'Save okay',
caption: 'OK'
})
.subscribe((yes) => {
this.service.getGoal().subscribe(
浏览 4提问于2022-02-10得票数 1
回答已采纳
2回答
我有一个这样的列表。如果问题的标题不正确，请原谅。
[array(['5029339601'], dtype=object), array(['5029339601'], dtype=object)]
我想把这个列表转换成一个普通的列表，比如
[ '5029339601' '5029339601']
对于这样一个模糊的问题，我事先表示抱歉。如果您的建议，我将不胜感激。谢谢
浏览 0提问于2021-05-20得票数 1
2回答
我在我的node.js服务器中查询一些数据，我希望结果是一个简单的字符串数组，但当我打印它时，结果如下所示：
[ ['element1'],[element2'],['element3'] ]
而不仅仅是['element1',element2','element3]
我本能地尝试打印数组，但这只打印出了数组的第一个元素，而不是第一个维度。
我是javascript的新手，我真的不理解这个行为。
非常感谢您的帮助！
浏览 3提问于2016-04-15得票数 0
我试图用我的头脑去理解CycleJS，但是我被卡住了！我正在尝试将一个小应用程序组合在一起，该应用程序加载一个包含对象数组的JSON文件，但我无法让该应用程序执行http请求
到目前为止在我的代码中
'use strict';
import Rx from 'rx';
import Cycle from '@cycle/core';
import {h, makeDOMDriver} from '@cycle/dom';
import {makeHTTPDriver} from '@cycle/http';
浏览 2提问于2016-04-19得票数 3
3回答
RxJS过滤器()算子
、、、、
我试图找到使用filter()操作符的最干净的解决方案，以便过滤我的可观测值。
在这里，我复制服务调用以分别获得一个femaleList
export class MyComp implements OnInit {
maleList: IContact[] = [];
femaleList: IContact[] = [];
constructor(private _contactService: ContactService) { }
ngOnInit() : void {
this._contactService.getCont
浏览 0提问于2016-12-13得票数 0
回答已采纳
3回答
目前，我有一个想要循环的多维数组。我想要的就是将内部元素推入一个空数组。但我得到的结果与预期输出完全不同。
到目前为止，所有的工作都完成在下面
const prices = [ [2, 20], [7, 50], [12, 100], [17, 40], [22, 32], [27, 25 ] ];
function addItemToCart() {
let new_items = [] // I want this array to be [2, 7, 12, 17, 22, 27]
// looping outer array elements
for(let i
浏览 10提问于2021-02-18得票数 0
1回答
我正在使用下面的选择器： export const selectorPersonData = createSelector(featureSelector, (state, props) => {
try {
return state.departmentData.filter(filt => filt.currentPosition.jobId === props.workSelectProps)
.map(job => job.assignedJob
.map(item => item
浏览 16提问于2019-12-06得票数 1
回答已采纳
1回答
这是我的代码：
<?php foreach ($classes as $str) foreach ($str as $class): ?>
...
<?php endforeach ?>
$str只有一个带有随机字符串索引的字符串值。
第一条语句是否可以优化为只有一条foreach？
浏览 0提问于2013-02-07得票数 0
回答已采纳
6回答
我有一个嵌套数组，如下所示
const names= [[{name: "John"}, {name: "Mary"}],
[{name: "Paul"}, {name: "Peter"}]];
我想将country注入到嵌套对象中
const country = {country :"USA"}
因此输出结果如下所示
[{name: "John", country : "USA"}, {etc} ,{etc} ]
代码构思如下所示
const combined
浏览 2提问于2018-11-20得票数 0
我现在拥有的：我有一个自定义的自动完成实现，在html中如下所示：
<input [formControl]="parentFormControl"
(mouseup)="autocomplete()"
(input)="autocomplete()">
<ul *ngIf="showAutocompleteList">
<li *ngFor="let listItem of autocompleteList; let index = index;"&
浏览 0提问于2018-10-04得票数 1
我有两个数组: listingMapIds和selectedFeePayload。我想要做的是，对于每个listingMapId，发送selectedFee的数量，也就是说，如果selectedFeePayload包含两个对象，那么每个listingMapId发送两个请求。下面是我的代码摘录： if (selectedFeePayload.length > 0) {
const response = yield all(listingMapIds.map(listingMapId => selectedFeePayload.map(fee =>
浏览 11提问于2021-07-07得票数 0
1回答
我有一段代码，在这里我试图捕捉所有的拖动事件。此代码仅适用于第一次拖动，停止将不适用于连续拖放。
是因为takeUntil取消了外部的可观测性吗？我怎样才能让代码工作。
const { Observable, fromEvent } = rxjs;
const { takeUntil, switchMap } = rxjs.operators;
const mouseups = fromEvent(document.querySelector('.container'),
'mouseup');
const mousedowns = fromEvent(d
浏览 1提问于2018-06-06得票数 1
回答已采纳
3回答
我试图迭代一个数组数组中的对象，但是，我无法在前端显示数据。 我尝试过这种方法： <div *ngFor="let item of events of event | keyvalue">
{{item.key}}:{{item.value}}
</div> 还有这一条： <div *ngFor="let item of events of event | json">
Test: {{item}}
</div> JSON数据的结构以这种格式给出。 [
[
{
浏览 20提问于2021-09-22得票数 0
回答已采纳
1回答
我是mongodb的新手。我将mongodb集合导出为csv文件，以便将其导入到我的sql服务器中。问题是其中一个字段是嵌套的。谁能告诉我如何处理该字段(地址)，以便它正确地插入到sql server中。所以这就是我的意思
这个集合是
Id |姓名|工资|员工、员工地址:员工、员工。
*||房号|街道|城市|乡村|
浏览 3提问于2015-05-07得票数 1
2回答
ngFor不显示数组
、、、
我有一个搜索服务：
getErros(start, end): FirebaseListObservable<any>{
this.hey = Rx.Observable.combineLatest(
this.db.list('/erros/geral',{
query: {
orderByChild: 'titulo',
limitToFirst:10,
startAt: start,
浏览 3提问于2017-07-13得票数 0
回答已采纳
我想要“书签”值顺流而下。更具体地说，来自这样的来源
import { of } from "rxjs";
let start$ = of(1,2,3);
我想要一个能放出
// 1-enter
// 1
// 1-exit
// 2-enter
// 2
// 2-exit
// 3-enter
// 3
我可以通过在中间添加一个主题来做到这一点，例如：
import { of, Subject } from "rxjs";
import { startWith, pairwise, delay } from "rxjs/operators";
浏览 5提问于2021-02-26得票数 1
回答已采纳
我有一个名为"DynamicFields“的对象的索引，每个对象都有名为"Fields”的内部对象，如下所示： {
"DynamicFields": [
{
"Fields": [
{
"DFieldVal": "Value1",
浏览 37提问于2019-04-23得票数 0
回答已采纳
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
即
import {of} from 'rxjs';
const sub = of(data).subscribe();
这有必要吗？
sub.unsubscribe();
浏览 2提问于2019-04-28得票数 6
2回答
我有一个数组。当我使用print_r($output)时。我像这样得到数组
array(
[0] => Array
(
[listing_id] => 14
[category_id] => Modern Australian
[listing_name] => Boatshed Restaurant
[image_name] => krish_logo.png
[addre
浏览 1提问于2015-06-02得票数 4
2回答
我正在尝试让数据绑定和tmpls - jquery插件很好地协同工作。因此，我想使用一个模板来呈现数据，然后使用数据绑定将其挂接到我的对象中。例如：
var items = [{ Name: 'Barak Obama', Phone: '555-1212' },
{ Name: 'George Bush', Phone: '444-2222'}];
function addItems() {
$("MyList").html("");
for (var i
浏览 2提问于2011-04-29得票数 1
回答已采纳
4回答
我有一系列的观测数据， const resultObservable: Observable<searchObject[]> [];
let i : 0;
keywordsArray.foreach(keyword => {
resultObservable[i] = getSearchResult(keyword); //function returns an array of observable searchObject
i++;
}); 现在我必须将所有的resultObservable连接在一起，我如何才能做到这一点呢？
浏览 27提问于2021-08-27得票数 1
回答已采纳
以以下场景为例：
Public Class Store
Public Overridable Property Areas As List(Of Area)
End Class
Public Class Area
Public Overridable Property Shelves As List(Of Shelf)
End Class
Public Class Shelf
Public Property ID as integer
End Class
获取商店货架总数的最快方法是什么？例如，对于商店，我通过使用Areas.Count获得区域的总数
或者我需要遍历
浏览 1提问于2012-04-05得票数 3
回答已采纳
2回答
使用.flatten是一个很方便的小技巧，可以将一个由子数组组成的数组转换成一个单独的数组。例如：[[1,3],2,[5,8]].flatten，=>，[1,3,2,5,8]，你甚至可以包含nil，[1,[2,nil],3].flatten将导致[1,2,nil,3]。
这种方法在嵌套.map方法时非常有用，但是如何处理空子数组呢？例如：[1,[2,3],[],4].flatten将返回[1,2,3,4]...但是，如果我需要跟踪空子数组，或者将结果转换为[1,2,3,0,4]或[1,2,3,nil,4]，该怎么办呢
有什么优雅的方法可以做到这一点吗？或者我是否需要编写一些方法来迭代每个
浏览 2提问于2017-02-22得票数 1
回答已采纳
在来这里之前，我已经阅读了Rxjs的官方文档和其他一些页面，但我仍然不清楚。我所理解的是：
它被用来“连接”两个可观测对象，从而获得一个可观测对象。因此，我还看到它被用来“扁平化”一个可观测对象(我也不是很清楚)。
现在..。。我花了几天的时间尝试使用Angular和Node.js在Express中编写用户注册表，我找到了一个我决定使用的小教程，其中包含以下代码：
import { Injectable, Injector } from '@angular/core';
import { HttpClient, HttpInterceptor, HttpRequest, H
浏览 0提问于2020-05-07得票数 0
我循环查看卡片组件，它循环了12次，所以调度动作发生了12次，我在console.log内部检查动作是否调度。我发现这种效果是有效的，但从存储中获取数据需要时间，而另一个操作会覆盖此操作。禁用覆盖之前的操作，我该怎么做？
@Effect()
getOrg: Observable<Action>
= this.actions.ofType(usersActions.GET_ORGANIZATION_DATA)
.map((action: usersActions.GetOrganizationData) => { console.log('e
浏览 0提问于2018-03-12得票数 0
我试图注入一个第三方脚本到一个页面，一旦它加载初始化视频播放器。
我希望能够在任何页面上有多个视频播放器，所以我有一些逻辑来检查脚本是否已经加载，并根据是否加载启动不同的操作。
我的“脚本加载”助手看起来像这样：
/**
* injectScript - Inject player script into page
* @param {String} id - script tag id
* @param {String} src - script src
* @return {Promise} - script load callback
*/
inje
浏览 2提问于2018-05-15得票数 0
我想记录这个数组中字母an的每次出现，期望的输出应该是3a，但没有，因为它确实是点读嵌套数组。 let items = [["a","b"],["c","a"],["b","a"]];
items.forEach((v) => (v === "a" && console.log(v)));
浏览 10提问于2021-09-26得票数 2
回答已采纳
"data": {"values": [{
"key": "test1",
"doc_count": 14,
"misc": {
"min": 5,
"max": 8,
"avg": 6.5
浏览 10提问于2018-12-20得票数 0
回答已采纳
1回答
我正在创建一个可观察的、需要执行几个步骤的步骤，每个步骤都依赖于前面的步骤--例如获取ID、使用ID来获取用户、使用该用户获取一篇文章。每个步骤都调用数据库，而数据库又返回自己的可观察到的数据。我真的不知道如何处理嵌套的可观测值而不订阅它们，或者确保当外部可观测值最终被订阅时，所有嵌套的可观测值也会被订阅。
示例：
newArticle(article: Article): Observable<any> {
// db api returns an observable of requests
return this.db.get(`select id from us
浏览 1提问于2021-12-23得票数 1
回答已采纳
1回答
当我尝试创建一个数据框来比较分类模型的实际(测试数据)和预测值时，我得到了一个错误。您可以在代码下面看到错误消息。代码的实现如下所示：
df = pd.DataFrame({'Actual': y_test, 'Predicted': y_pred})
df
ValueError Traceback (most recent call last)
<ipython-input-22-45d19b608f98> in <module&g
浏览 37提问于2021-05-26得票数 0
回答已采纳
我一直在努力解决这个问题，感觉我有一个根本性的误解。我使用的是React中的redux-observable库，它将redux与RxJS粘合在一起来处理异步。我的问题是我必须处理一个大的上传，我想在文件加载时显示进度。
函数uploadFileEpic需要返回一个Observable<Action>才能使用redux-observable。uploadObservable表示我想要完成的工作流程。如果我只是返回uploadObservable，那么上载就可以工作了，但是在ajax调用中，我没有从progressSubscriber获得任何handleUploadFileProgre
浏览 1提问于2018-12-15得票数 4
我试图打印这个数组1,2,3中所有组合的所有不同和。我想首先将每个求和结果推入一个新的数组b，然后使用b.uniq打印它们，这样所有求和结果都不会重复。然而，在我的代码中，3会重复自己，我认为这是因为它被推入数组b的方式。
有没有更好的方法来做这件事？
a = [1,2,3]
b = []
b.push a
b.push a.combination(2).collect {|a,b| (a+b)}
b.push a.combination(3).collect {|a,b,c| (a+b+c)}
puts b.uniq
p b #[[1, 2, 3], [3, 4, 5], [6]]
浏览 0提问于2015-10-26得票数 2
下面是Ngrx示例的代码：我的问题是，为什么在第一个@Effect中，它使用switchMap，而其他@Effect使用mergeMap。这是不是因为第一个@Effect是处理网络，并且如果switchMap正在运行，您可以取消之前的网络请求？
@Effect() search$ = this.updates$
.whenAction(BookActions.SEARCH)
.map<string>(toPayload)
.filter(query => query !== '')
.switchMap(query =>
浏览 4提问于2016-07-21得票数 60
在SQL Server中，有没有办法让嵌套的case语句继续嵌套的CASE语句？
CASE
WHEN ... then
CASE
WHEN ... THEN
ELSE **[Continue to below WHEN]** END
WHEN ... then
WHEN ... then
ELSE ... END
我想知道我是否可以通过不将正在进行的WHEN语句复制/粘贴到嵌套的CASE中来保持代码的整洁。
浏览 4提问于2021-09-17得票数 0
2回答
我在js文件中声明了以下数组
var myApp = angular.module('myApp',[]);
function MyCtrl($scope) {
$scope.name = 'Superhero';
$scope.tempArr = [
["block A1", "block B1", "block C1"],
["block A2", "block B2", "block C2"]
];
}
现在在an
浏览 0提问于2015-11-02得票数 0
我正在使用一个可观察的查询数据库。此可观测对象将返回一个数组，其中包含所有匹配的对象。我的问题是，我想用从另一个API检索的更多细节来映射可观察到的内容。
我尝试了concatMap，但它只允许我在初始可观测范围内嵌套一个可观测的
const usersAPI$: Observable<Users[]> = // something
const assistsAPI$: Observable<Assists[]> = // something
const modifiedAssists$ = assistsAPI$.find().pipe(
concatMap
浏览 0提问于2019-04-07得票数 8
回答已采纳
2回答
我有两个数组，我想把它们组合起来
import numpy as np
a = np.array([[1,2,3],[4,5,6]])
b = np.array([[7,8,9],[10,11,12]])
c = np.array([[13,14,15],[16,17,18]])
要获得以下信息：
array([1,2,3,7,8,9,13,14,15, 4,5,6,10,11,12,16,17,18])
它的功能是什么？
谢谢:)
浏览 2提问于2017-02-27得票数 9
回答已采纳
3回答
以下是工作代码：
p = (10..14).map { |a|
(a..14).map { |b|
a * b
}
flatten.select { |p|
p.to_s == p.to_s.reverse
}
但我想保留产生'a *b‘的'a’和'b‘的信息：
p = (10..14).map { |a|
(a..14).map { |b|
[a, b, a * b, '=']
}
}.select { |v|
v[2].to_s == v[2].to_s.reverse
}
puts p
此代码打印的不是回文
浏览 1提问于2011-03-26得票数 1
回答已采纳
我正在和switchMap操作符玩，以清楚地了解“切换”内部可观察到的发生了什么。
起初，我认为switchMap只是从可观察到的开关内部“取消订阅”，但后来我意识到它实际上是“取消订阅和完成”的内部可观测性。
为了确认我已经写了这个小片段：
如您所见，当主题第二次发出时，将正确地调用finalize()操作符，但是：
为什么tap运算符的完整处理程序不称为？
这让我对这个操作人员的理解只感到80%的满意。
A与此无关：
我阅读和观察过许多关于switchMap的消息来源，包括：
这个(很好的) ngconf来源：
官方的rxjs文档：
它们中没有一个清楚地说明内部可观测性是未
浏览 0提问于2019-08-28得票数 1
回答已采纳
2回答
热与冷观测
、、
在RxJS中，热观测是使用外部生产者的可观测性，而冷可观测的是使用本地生产者(参见)。
无论何时打电话，HttpClient.post都会使用冷观测值发送数据和重复。
有什么方法可以从角度上判断某一特定方法是否使用了可观察到的热或冷？
浏览 0提问于2017-09-06得票数 10
回答已采纳
1回答
我正在尝试将数组数据映射到列名列表 cols = list(X.columns)
a = log_reg.coef_
pd.Series(data=a,index=cols) 但是一直收到这个错误消息 ValueError: Length of passed values is 1, index implies 32 中的数据示例。 array([[-3.45917636e-04, 3.61924667e-01, -4.09270503e-01,
-8.77365851e-01, 2.63110856e-01, 1.19371203e-01,
-1.24
浏览 18提问于2019-06-04得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
