正在取消observable中的fetch方法
取消observable中的fetch方法是指停止对一个可观察对象（observable）中使用fetch方法进行网络请求的操作。fetch方法通常用于向服务器发送HTTP请求并获取响应数据。
取消observable中的fetch方法可以通过以下步骤进行：
- 首先，需要创建一个取消令牌（cancel token），用于指示取消操作。这可以通过使用Promise.race方法和AbortController来实现。AbortController是一个内置的浏览器API，用于向fetch请求添加取消功能。
- 在observable中的fetch方法被调用时，可以使用AbortController.signal属性作为fetch请求的signal参数，以便在取消令牌被触发时中断请求。
- 当需要取消observable中的fetch方法时，可以通过调用取消令牌的
abort()方法来触发取消操作。这将导致fetch请求被中断，并触发一个AbortError。
取消observable中的fetch方法的优势在于可以提高网络请求的灵活性和性能，避免不必要的请求和响应数据的传输，节省带宽和服务器资源。它可以在以下情况下应用：
- 用户取消操作：当用户执行了某个操作后，又想取消正在进行的网络请求时，可以使用取消observable中的fetch方法。
- 页面导航：当用户在页面导航过程中切换到其他页面，可以取消当前页面上的未完成的网络请求，以提高用户体验和页面加载速度。
- 错误处理：当网络请求出现错误或超时时，可以取消observable中的fetch方法，避免后续处理不必要的数据。
腾讯云提供了一系列与云计算相关的产品，以下是一些推荐的产品和其介绍链接：
- 云服务器（ECS）：提供灵活的云服务器实例，可按需调整计算资源。了解更多：https://cloud.tencent.com/product/cvm
- 云数据库 MySQL（CDB）：基于高可用架构的云数据库服务，支持自动备份、容灾、性能优化等功能。了解更多：https://cloud.tencent.com/product/cdb
- 云原生容器实例（TKE）：提供弹性的容器实例服务，支持容器化应用的高效部署和管理。了解更多：https://cloud.tencent.com/product/tke
- 云存储 COS：面向企业和个人提供可靠、安全、低成本的对象存储服务，适用于图片、视频、文档等各种类型的数据。了解更多：https://cloud.tencent.com/product/cos
请注意，以上仅是一些示例产品，腾讯云还提供其他丰富的云计算解决方案和产品，可根据具体需求选择相应的产品。
相关·内容
1回答
我想在取消订阅返回的observable时取消fetch方法 那么为什么我要返回()=>controller.abort()呢？ 为什么当我取消订阅()时才调用此方法 createHttp(url: string) {
return new Observable((observer) => {
const controller = new AbortController()
const signal = controller.signal
fetch(url, { signal })
.then((response) => response.json()
浏览 20提问于2021-05-10得票数 0
回答已采纳
我正在玩rxjs，目的是掌握JS中的反应性和函数式编程。
我有以下琐碎的应用程序：
import Rx from 'rxjs'
const domContainer = document.querySelector('[data-container]')
const clickElement = document.querySelector('[data-init-fetch]')
const loader = document.querySelector('.loader')
// only emit when all t
浏览 2提问于2018-03-20得票数 1
回答已采纳
2回答
我有一个史诗般的动作，它将公司从本地服务器中提取出来，在React组件的componentDidMount方法中分派。使用返回的数据，我实例化模型并将它们传递给完成其工作的还原器。
史诗动作如下所示：
export const fetchCompaniesEpic = (action$: Observable<Action>): Observable<Action> =>
action$.pipe(
ofType(FETCH_COMPANIES),
delay(5000),
switchMap((action
浏览 0提问于2018-09-01得票数 2
我使用Observable.create，以便在某些数据可用时通知订阅者。在我的创建方法中，我对订阅可观察到的内容有点不确定。这些嵌套订阅会给我带来任何问题吗？我不太熟悉使用Observable.create创建可观察性，所以我想确保我没有做任何异常或滥用它的事情。提前谢谢你！
abstract class NetworkResource<ApiType, DbType> constructor(private val schedulerProvider: SchedulerProvider) {
abstract fun fetchFromApi(): Single&l
浏览 3提问于2017-06-12得票数 3
回答已采纳
我正在尝试将一些基于侦听器模式的API封装到一个可观察对象中。我的代码大致如下所示。
def myObservable = Observable.create({ aSubscriber ->
val listener = {event ->
aSubscriber.onNext(event);
}
existingEventSource.addListener(listener)
})
但是，当观察者调用subscription.unscribe()时，我希望我的observable立即从底层existingE
浏览 32提问于2014-11-02得票数 20
回答已采纳
我正在尝试用RXAndroid创建一个重复的后台计时器。我已经编写了在后台以指定时间间隔执行的代码，但我无法找到阻止它的方法。
Observer<Long> observer = new Observer<Long>() {
@Override
public void onSubscribe(Disposable d) {}
@Override
public void onNext(Long aLong) {
Log.d(LOGTAG, "Interval:" +
浏览 0提问于2017-10-30得票数 0
回答已采纳
1回答
我在更新数组时遇到了让MobX渲染的问题。以下是代码的简化版本： import React, { useState } from 'react'
import { flow, makeObservable, observable } from 'mobx'
import { observer } from 'mobx-react'
import { ResourceList } from './ResourceList'
import { ResourceItem } from './ResourceItem'
浏览 51提问于2021-01-08得票数 4
回答已采纳
我对下面的代码有一个问题。传入的观察者正在调用中使用。例如observer.next("bla bla bla")。
如果我传入observer.next，我不明白它是如何存在的？
import { Observable } from "rxjs/Observable"
// create observable
const simpleObservable = new Observable((observer) => {
// observable execution
observer.next(
浏览 0提问于2019-08-23得票数 1
我理解由于缺乏背压支持而使用Observable.create 。因此，我已经开始使用新的Observable.fromAsync来包装回调API，因为它以与Observable.create相同的行为来处理背压。
然而，在中，似乎有这样的建议:将我创建的可观察到的内容公开如下，应该可以解决这个问题：
Observable<T> observable = Observable.create(onSubscribe).onBackpressureBuffer();
这是正确的吗？在这一点上，这两个操作符的区别是什么？如果这不正确，是否有理由在.fromAsync上使用.fromAsy
浏览 2提问于2016-07-29得票数 4
回答已采纳
我有来自‘’的以下代码：
const Observable = require('rxjs/Observable').Observable;
require('rxjs/add/observable/of');
require('rxjs/add/operator/map');
let stream = Observable.create((observer) => {
let i = 0;
let id = setInterval(() => {
observer.next(i++);
}, 500);
浏览 0提问于2017-06-21得票数 1
回答已采纳
2回答
我阅读了大量关于在角中不订阅Observable的帖子，它们都提到了只在组件/指令中这样做的必要性。
所以我的问题是：
我们是否需要在非组件/指令类中从Observable中取消订阅，例如在服务中，或者基本上包含对Observable的订阅的任何其他类中？
浏览 6提问于2017-09-26得票数 4
回答已采纳
2回答
我已经在我的代码库中实现了这个结构(UI，ViewModel，Repo，Data )。当我想取消Retrofit中的请求时，会出现一个问题。
我的限制是：
当用户取消请求时，我需要跟踪事件。
当片段/活动被用户拒绝时(假设生命周期在onDestroy中)，它将被视为取消操作。
在这种结构下(使用NetworkBoundResource也没有取消请求的控制)，我如何在修改时取消请求？
感谢任何评论或回答，或者如果有更好的实现来解决这个问题，我会给它一个尝试。
MyViewModel.java
public class MyViewModel extends ViewModel {
浏览 1提问于2018-06-28得票数 1
2回答
我希望创建一个运行长轮询操作的rxjs Observable。每次迭代都会产生中间结果。当isComplete返回true时，Observable就完成了。
此函数应如下所示
只有当存在至少一个subscriberIt时才能启动--应该允许多个订阅者共享结果--如果存在，则应该中止轮询并调用cancel，如果没有订阅服务器，就应该退出<code>H 216</code><code>G 217</code>
以下代码工作正常，满足条件(1)和(2)：
function longPollingAction(fetch: () => Promis
浏览 3提问于2021-03-25得票数 4
回答已采纳
1回答
如何循环史诗调用
、、、、
我有以下史诗：
import {
map,
catchError,
switchMap,
takeUntil,
} from 'rxjs/operators';
import {
FETCH_JOKES,
jokesReceived,
FETCH_JOKES_CANCELLED,
jokesFetchFailed,
} from '../actions/jokes-action';
import { ofType } from 'redux-observable';
import { of, concat } fr
浏览 0提问于2018-09-25得票数 1
回答已采纳
我正在与Rxjava2 接线员合作。我创造了两个可观察的实验。
可观测1:
Observable<String> observable1 =
Observable.defer(new Callable<ObservableSource<? extends String>>() {
@Override
public ObservableSource<? extends String> call() throws Exception {
return Observable.create(new ObservableO
浏览 0提问于2018-03-17得票数 0
回答已采纳
我正在尝试使用payload.type = 'observable‘分派'SET_MIDDLEWARE_TYPE’操作，等待5秒，然后进行API调用。当前未调度SET_MIDDLEWARE_TYPE操作。如果我删除了延迟和mergeMap，它就会分派该操作。
预期: FETCH_USER_WITH_OBSERVABLE_REQUEST --> SET_MIDDLEWARE_TYPE (等待5秒) --> FETCH_USER_WITH_OBSERVABLE_SUCCESS
实际: FETCH_USER_WITH_OBSERVABLE_REQUEST --> (
浏览 10提问于2017-01-21得票数 1
回答已采纳
我有一个多输入的列表(动态生成-未知的数字)。
我希望每个按键都触发一个ajax请求。
我希望这些ajax请求排队，因此一次只向服务器发送一个请求，而下一个请求只有在从前面的服务器获得响应后才发送。
如果从队列中已有请求的输入触发新请求，我希望取消与同一输入关联的旧请求。
如果从队列中没有输入的输入触发新请求，我希望只将新请求添加到队列的末尾，而不取消任何内容。
有人告诉我，RxJS使这类复杂的异步操作变得容易，但我似乎不能把头转到所有的RxJS操作符上。
我在下面使用一个输入排队，但我不太明白为什么需要延迟，或者如何在保持类似于开关图的行为的同时，对单独的输入请求进行
浏览 0提问于2018-03-26得票数 0
1回答
我想创建一个异步循环，它会一直运行到用户按下停止按钮。然而，我对f#还是比较陌生的，不确定如何做到这一点。Async.AwaitObservable()永远等待用户输入，而Async.Sleep()显然根本不接受任何用户输入。
任何帮助都会非常感谢，我现在的代码是这样的：
open FSharpx.Control.Observable
open System.Windows.Forms
module Gui =
let form = new Form(Text="I do loops", TopMost=true, Width=250, Height=250)
浏览 0提问于2018-02-20得票数 2
回答已采纳
问题
Observable.of将参数转换为可观测序列，这意味着它可以用作对另一个可观察的订阅的模拟响应。但是现在，当它从拦截器调用时，Observable.of似乎无法工作，因为订阅它的方法不执行。
预期行为：
当用给定的数据调用Observable.of时，HttpClient应该将数据返回给已经订阅它的方法。
演示
(打开DevTools控制台读取日志)
有一个服务(mock.service.ts)使用HttpClient发出模拟HTTP请求，该请求到达mock.interceptor.ts并希望使用Observable.of回答模拟数据(意思是不允许请求通过网络)，mock.serv
浏览 3提问于2017-12-04得票数 0
回答已采纳
1回答
我正在尝试为AuthHttp服务(angular2-jwt)创建一个‘拦截器’。我创建了一个扩展AuthHttp的类，并改用它。到目前为止，它似乎工作得很好。我现在想要做的是，如果服务器响应401代码是为了在我的应用程序中强制注销并忽略后续订阅(我不确定这些订阅是否按顺序执行，所以我不知道我将询问的内容是否可能)。
因为我只想在这个场景中显示一个错误，所以我只需要从这个订阅中中止队列并忽略进一步的订阅。下面是我到目前为止获得的get方法的代码：
get(url: string, options?: RequestOptionsArgs): Observable<Response>
浏览 3提问于2016-11-23得票数 0
2回答
我有一个angular应用程序，我正在读取一个文件并处理它，这个处理是observable的一部分。我有一个服务，它返回可观察到的an (ngbusy:subscription)。我在我的组件中订阅了这个观察值。observable被分配给一个显示微调器的ngBusy。现在，即使在订阅完成后，旋转器也会继续旋转。我知道我们需要取消订阅obervable。但是，当我使用与订阅相同的方法取消订阅时，我甚至看不到微调控件的显示。我们是否应该总是使用ngOndestroy来取消订阅。
service.ts
const obsrv:Observable
obsrv= new Observable((ob
浏览 0提问于2018-04-28得票数 0
1回答
在反应式打字项目中使用mobx。该类使用fetch api设置可观察数组：
class MenuRepo {
@observable menuItems?: IMenuModel[];//=[{Id:1,itemName:"asd",childItems:[]}];
@action getItems(): void {
fetch(`...`)
.then((response: { value: IMenuModel[] }): void => {
this.menuItems = [
{ Id: 1, it
浏览 3提问于2017-02-19得票数 2
回答已采纳
我们是否需要在一个可观察的对象中返回我们自己的拆卸逻辑或取消订阅方法？
const observable = new Observable(function subscribe(subscriber) {
// Keep track of the interval resource
const intervalId = setInterval(() => {
subscriber.next('hi');
}, 1000);
// Provide a way of canceling and disposing the interval resou
浏览 5提问于2021-03-24得票数 0
我正在尝试在Angular2中使用switchMap取消任何以前的http调用。代码基本上是
var run = ():Observable<any> => {
var url = 'http://...'
return this._http.get(url)
.map(result => {
return var xmlData:string = result.text()
});
}
function pollTask
浏览 0提问于2016-03-03得票数 15
我正在使用一个可观察的间隔，每5秒在某个组件内执行某个函数，这与我的路由配置中的路径相关。
Observable.interval(5000).subscribe(res => {
// Something happens here
});
但是，当路径更改时，我希望终止间隔。现在它继续执行任务..。
做这件事最好的方法是什么？
浏览 3提问于2016-04-30得票数 7
回答已采纳
我正在使用RxJava (可观察到的自定义缓存)做一些工作，我发现了以下问题。
示例简单明了:创建可观察的订阅者并立即取消订阅。
public static void main(String[] args) {
Observable<Long> origin = Observable.create(new Observable.OnSubscribe<Long>() {
@Override public void call(Subscriber<? super Long> subscriber) {
try {
浏览 4提问于2015-11-26得票数 1
1回答
我正在实现Observable，它应该只是从网络下载一个分成多个部分的文件。
下面是我的实现
private static class MultipartDownloadObservable extends Observable<String> implements Cancellable {
@Override
protected void subscribeActual(Observer<? super String> observer) {
// Start loading
subscri
浏览 4提问于2017-11-29得票数 0
1回答
如何取消正在运行的store.dispatch(xxx)操作，使底层的http请求也被取消？
我尝试从store.dispatch(new FetchSomeStuffOverHttp())调用中执行.unsubscribe()，并预计底层的http请求也会被取消。
但它将继续运行，即使该操作返回了httpClient的observable：
@Action(FetchStuffOverHttp)
fetchStuffOverHttp({ patchState }: StateContext<AuftragStateModel>) {
return this.httpClien
浏览 1提问于2020-04-02得票数 2
1回答
有一个函数从服务器调用API来返回Observable<DataFromServer>。
我希望将其转换为UI中的必要数据，并使其成为Observable<[DataForUI>。
我做了一个示例，如下所示，但我想简化转换部分。
你能告诉我有没有办法吗？
// Models
struct DataFromServer {
var name: String
var score: Int
}
struct DataForUI {
var displayName: String
var displayScore: String
}
// API funct
浏览 1提问于2021-04-23得票数 1
回答已采纳
1回答
来自PHP的角度2观测值
、、、
我对Observables in Angular2有点陌生。据我所知，每当数据发生变化时，它们都会向subscribers发出更改。实际上，我从我的php后端获得了初始运行上的第一个响应。
但是，如果我更改或更新数据库中的内容，the observable cant fetch the next changes again. It will only update upon refresh
我的服务
checkField(_options : T):Observable<any>{
this.options = _options;
let x = this.seri
浏览 4提问于2017-03-08得票数 1
回答已采纳
我正在构建一个Angular5项目，其中我必须使用http。我在这里使用的是observable，但是当我使用'of‘时
scope.fetchApi = Observable.of(data);
然后它会给我一个错误：
Property 'of' does not exist on type 'typeof Observable'.
我也导入了'rxjs/add/observable/of';，但同样的错误也在那里。我也尝试过import { Observable } from 'rxjs/Observable';，
浏览 85提问于2018-06-10得票数 6
回答已采纳
我已经编写了一个函数，该函数返回一个可观察到的包装onSnapshot方法的函数。
function getObservable() {
return Observable.create(observer => {
firebase.firestore().collection('users').onSnapshot(
snapshot => observer.next(snapshot.docs),
);
});
})
}
我能够使用这个函数并获得如下更新的文档
const observable = getO
浏览 0提问于2018-10-17得票数 1
回答已采纳
在Javascript中，何时抛出此错误？
index.js
/**
* Created by tushar.mathur on 24/12/15.
*/
'use strict'
const _ = require('lodash')
const Rx = require('rx')
const createDataStore = require('./src/createDataStore')
const fetch = x => Rx.Observable.fromPromise(window.fet
浏览 9提问于2016-01-14得票数 58
回答已采纳
1回答
同步RxJs取消订阅不起作用
、、、、
演示：
代码下面的不工作
错误:无法读取未定义的属性“取消订阅”
const a = (): Observable<any> =>
new Observable(sub => {
sub.next(1);
return () => {
console.log('unsubscribe');
};
});
const observer = a().subscribe(
value => {
console.log('Subs
浏览 1提问于2020-02-12得票数 0
我正在寻找最优雅的方式来完成以下任务。我知道有多种方法可以做到这一点，而且有多种方法遵循反模式(当然，这里我不想要:订阅中的订阅)。
我的圈套
export class MyService {
giveMeTheBest(...): Observable<TheBest> {
const observable1$ = // Fancy request, returning an Observable
const observable2$ = // A request to a different endpoint, also returni
浏览 1提问于2020-09-15得票数 0
回答已采纳
考虑以下示例，它创建了一个包装了另一个生成Widgets的Observable的API
public Observable<Widget> createWidgetObservable() {
return Observable.create(new Observable.OnSubscribe<Widget>() {
@Override
public void call(final Subscriber<? super Widget> subscriber) {
浏览 0提问于2015-12-02得票数 2
我已经在角2中创建了一个HttpInterceptor。拦截器的代码位于导出类HttpInterceptor扩展HTTP {
private httpSubject = new Subject<Message>();
httpSubject$ = this.httpSubject.asObservable();
private block : boolean = true;
constructor(backend: ConnectionBackend, defaultOptions: RequestOptions, private _router: Route
浏览 2提问于2016-11-07得票数 0
回答已采纳
1回答
我们目前正在开发一个Angular4应用程序，并寻求对服务体系结构的反馈。
应用程序的五个“模块”是：
一
二
三
四
五
目前，我们有一个特定于one的数据服务，但是，抽象类ApiService可以跨其他四个模块导入(参见下面的代码)。
以下是我所想的一些选择：
选项1:将抽象类ApiService移到共享文件夹模块中，即将共享文件夹模块导入到五个模块中的每个模块中。
然后创建一个特定于每个模块的服务，该服务是从ApiService继承的。这将使管理每个单独的服务变得更加容易。
选项2:将抽象类移动到共享文件夹中，并创建一个包含所有五个模块的所有api调用的全局服
浏览 1提问于2017-07-13得票数 3
回答已采纳
1回答
我正在尝试实现一个定时器Observable，它在我的应用程序的Activities之间共享。我是在一个类上实现的，这个类是一个Dagger，我在每个不同Presenter的Activity中注入它。
我创造了一次可观察的方法：
Observable.defer(() -> Observable.timer(milliseconds, TimeUnit.MILLISECONDS).map(t -> this::doSomethingCool()))
.subscribeOn(Schedulers.newThread())
.obser
浏览 2提问于2017-02-07得票数 3
1回答
我注意到在compose方法中，这个observable可以绑定到一个activity生命周期来执行所需的取消订阅，问题是我是在一个服务中这样做的，所以我不能使用这个库，或者至少我不知道如何获得这个服务生命周期并将observable绑定到它：
return bleDevice
.establishConnection(false)
.takeUntil(disconnectTriggerSubject)
//.compose(RxLifecycle.bindUntilEvent(MISSINGACTIVITYLIFECY
浏览 3提问于2017-12-20得票数 0
我一直在使用 for 创建一个实现。
从高级别发送HTTP请求，并保持连接处于打开状态。长度前缀项被发送到消费。
基本上，它是在循环中调用，使用。一个实现(从或者从的一个块，没关系，它是一个实现细节)传递到这个循环，然后这个循环调用IObserver<T>实现上的metods，生成可观察的方法。
但是，在这个循环开始处理需要调用-returning方法之前，还有很多事情要做，所有这些都更容易在C# 5.0中使用await关键字进行调用。就像这样：
public async Task<IObservable<string>> Create(string par
浏览 0提问于2013-03-31得票数 6
回答已采纳
我正在苦苦思索如何在redux-observable epic中测试retryWhen操作符。基于取自的，我派生了，其中我尝试测试响应失败2次之后返回有效响应的情况。
下面是代码的一部分。对于整个实现，请使用
let RetryStrategy = attempts => attempts
.zip(Observable.range(1, 4))
.flatMap(([error, i]) => {
if (i > 3) {
return Observable.throw('Network error occur
浏览 16提问于2017-08-07得票数 3
我有一个简单的retrofit2 api接口，它包含
interface Api {
@GET(BuildConfig.END_POINT) Observable<Response> fetchData();
}
所以，当我做一个新的请求时，一切都很好，但是假设我触发了一个请求，我立即取消订阅，然后我尝试触发新的请求，它什么也没有返回。
因此，在代码中，它看起来像这样：
在Activity::onPause中，我执行取消订阅，在Activity::onResume中，我再次触发请求。
我的请求类似于：：
api.fetchData()
.timeout(30,Tim
浏览 0提问于2016-06-12得票数 3
我正在学习RxSwift，在创建可观察对象时，我遇到了以下模式：
return Observable.create { observer in
let disposable = Disposables.create()
// Do some stuff with observer here
return disposable
}
据我所知，返回的Disposable实际上并没有做任何事情，除了满足返回Disposable的API要求之外，它还有其他用途吗？
是否存在可能需要返回已配置的Disposable的场景？
我想最让我困惑的是，返回的Disposable似乎
浏览 0提问于2018-08-31得票数 11
2回答
我需要从网络中请求不同类型的模型，然后将它们合并成一个模型。如何能够连锁多个可观测到的，并返回另一个可观测的？
我有这样的东西：
func fetchDevices() -> Observable<DataResponse<[DeviceModel]>>
func fetchRooms() -> Observable<DataResponse<[RoomModel]>>
func fetchSections() -> Observable<DataResponse<[SectionModel]>>
浏览 3提问于2017-08-02得票数 1
回答已采纳
1回答
我用的是RxJ的角度2。我得到以下编译异常，
[ts]
Type 'Observable<Observable<B>>' is not assignable to type
'Observable<B>'.
Type 'Observable<B>' is not assignable to type 'B'.
Property 'id' is missing in type 'Observable<B>'.
下面是正在讨论的代
浏览 1提问于2017-06-04得票数 0
回答已采纳
2回答
我只想在html中还原一个valure：
<tr *ngFor="let valCorr of valueCall| async">
<th>{{valCorr }}</th>
</tr>
在ts中
valueCall:Observable<number[]>
//this.studentService.getResult() return an Observable<number[]>
this.valueCall:Observable=this.studen
浏览 5提问于2022-10-19得票数 0
例如，我正在寻找如何使用redux-observable Next.js的getInitialProps钩子来处理 ajax史诗。有可能吗？
换句话说，如何在getInitialProps中利用这一点：
import { ajax } from 'rxjs/observable/dom/ajax';
// action creators
const fetchUser = username => ({ type: FETCH_USER, payload: username });
const fetchUserFulfilled = payload => ({ t
浏览 3提问于2017-09-23得票数 0
我有一个带有节点/快递的模拟api设置
http://localhost:8080/api/lyric/
我正在使用redux可观察的方法来获取json：
const fetchLyricEpic = action$ =>
action$.ofType(FETCH_LYRIC)
.mergeMap(action =>
ajax.getJSON('/api/lyric')
.map(response => fetchLyricSuccess(response))
.catch(error => Observable.of
浏览 7提问于2017-04-23得票数 0
回答已采纳
我正在尝试使用Firebase v9模块化版本，我对如何使用onSnapshot感到困惑。我正在尝试执行一个查询并侦听文档。
以下是我的代码：
getUsersBoards(){
return this.authService.currentUser$.pipe(
filter((user)=> !!user),
mergeMap(async (user) => {
const collectionRef = collection(this.firestore, 'boards');
con
浏览 5提问于2022-03-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
