类型'Observable<any>‘上不存在属性'startWith’
类型'Observable<any>'上不存在属性'startWith'。
这个错误提示表明在类型为'Observable<any>'的对象上使用了'startWith'属性，但该属性在该类型上不存在。通常情况下，'startWith'是RxJS库中Observable对象的一个操作符，用于在Observable流的开头插入一个初始值。
要解决这个问题，可以按照以下步骤进行：
- 确保你已经正确导入了RxJS库。可以使用以下导入语句：
import { Observable } from 'rxjs';
import { startWith } from 'rxjs/operators';- 确保你正在操作一个Observable对象。可以检查你的代码中是否有一个类型为'Observable<any>'的对象。
- 确保你正在正确使用'startWith'操作符。该操作符应该在Observable对象上调用，并且可以接受一个初始值作为参数。例如：
const myObservable: Observable<any> = ...; // 假设这是你的Observable对象
myObservable.pipe(startWith('initial value')).subscribe(...);在这个例子中，我们在Observable对象上使用了'startWith'操作符，并传入了一个字符串'initial value'作为初始值。
总结起来，要解决这个错误，你需要确保正确导入了RxJS库，操作的是一个Observable对象，并且正确使用'startWith'操作符。如果你需要更多关于RxJS的信息，可以参考腾讯云的RxJS相关产品和文档：
相关·内容
用这个代码
const start$ = Observable.fromEvent(this.getNativeElement(this.start),'click');
const stop$ = Observable.fromEvent(this.getNativeElement(this.stop),'click');
const interval$ = Observable.interval(1000);
const data = {count:0};
const intervalThatStops$ = interva
浏览 4提问于2017-03-05得票数 0
我有一个Observable.interval(600000)，它每10分钟运行一次。一个组件订阅了它，它工作得很好。但我想要的是，当应用程序加载时，有没有办法让它自动运行，而不影响它600000毫秒的间隔时间？ 注意:代码被大量缩短以表明观点。 @Injectable()
export class CalculateService {
result: Subject<any> = new Subject<any>();
constructor(
) {
Observable.interval(600000)
.subscrib
浏览 38提问于2019-02-07得票数 1
回答已采纳
我可以在rxjs文档()中读到关于方法扫描的一个种子论证。
在下面的代码中，我想返回_channels可观察值的默认值。
export interface IChannelOperation extends Function {
(channels: Channel[]): Channel[];
}
let initialChannel: Channel[] = [];
@Injectable()
export class ChannelsCatalog{
defaultChannel: Subject<Channel> = new BehaviorSubject&
浏览 0提问于2017-01-13得票数 2
回答已采纳
我使用另一个Observable的输入过滤一个Observable --过滤的输入来自用户。
过滤由RxJS运算符combineLatest完成。使用这意味着，当订阅该流时，在两个源可观测到的源发出信号之前，不会发出任何值--我希望在创建时(没有任何过滤)，在发生任何用户输入之前，创建的流发出。
我认为我应该使用操作符，这样流在创建时就有了发射，但是我无法从一个可观察到的地方找到这个种子。使用可观察到的数据，因为数据来自Firebase，并由FirebaseListObservable处理。
下面是一个拼凑的版本，我正在做的事情。
let tagInput = document.getElem
浏览 8提问于2016-12-30得票数 10
回答已采纳
我试图找出一个很好的RxJS模式的切换样式按钮/链接，基本上限制了一个数组的视图。
它在两个值之间切换，其中一个是静态的，另一个来自可观察的(实际上是http请求的结果，this.itemsArray$)。
ts
this.toggleClicks$ = Observable.fromEvent(this.viewAllToggle.nativeElement, 'click')
.scan(prev => !prev, false);
this.itemsArray$ = Observable.of([ /* array of any */ ]);
th
浏览 3提问于2017-04-13得票数 0
我有一种实用方法(用于角度反应形式的脏检查)：
private checkIsDirty(valueChanges: Observable<any>, sourceEntity: any, createEntityFromFormValue: (frmVal: any) => unknown): Observable<boolean> {
return valueChanges.pipe(
debounceTime(400),
distinctUntilChanged(),
map(creat
浏览 7提问于2022-07-23得票数 0
回答已采纳
我试图使用Observable来呈现两个项目列表。一个具有完整的结果，另一个具有过滤的结果。
我有这样的组成部分：
@Component({
template: `
<div *ngFor="let item of items | async">
<span>{{item.name}}</span>
</div>
<input [formControl]="filterControl" />
<div
浏览 5提问于2016-11-02得票数 1
回答已采纳
当我尝试使用“角材料自动完成”添加标记时，它会在构造函数中崩溃，出现以下错误：
ERROR TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.
at Object.push../node_modules/rxjs/internal/util/subscribeTo.js.exports.subscribeTo (subscribeTo.js:42)
at Object.s
浏览 0提问于2018-06-16得票数 1
回答已采纳
我想创建一个从webapi返回数据的可观察对象。我希望它立即返回数据，并每10秒轮询一次API。下面的代码显示我使用的是“interval”方法。但这会将第一组数据延迟10秒。如何才能在没有初始延迟情况下获得第一次刷新数据？
export class EventService {
public events$: Observable<Event[]>;
private _eventsObserver: Observer<Event[]>;
private pollInterval: number = 5000;
private _dat
浏览 1提问于2016-04-14得票数 39
1回答
我在一个视图中有两种形式，每种形式都输出更改。我有一个带有两个选择器的全局指令来获得这两个流。
我可以很容易地处理一个表单，但是当我有两个表单，并将每个表单放置在自己的管道或指令中时，它们会把对方的保存函数搞得一团糟，也就是说，我需要将它们放在同一个管道中。(或另一种解决办法;)
表单组件
<form name="shop_info"
autocomplete="off"
#f1="ngForm"
(SubmitShop)="save($event)"
[SaveShop]=&
浏览 3提问于2019-10-17得票数 0
1回答
我从远程服务器获取数据。配置了CORS。我使用RXJS库中的interval()运算符。
组件：
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/interval';
import 'rxjs/add/operator/switchMap';
private getUserTasks(userId): void {
Observable
.interval(5000)
.switchMap(() => thi
浏览 9提问于2017-12-14得票数 0
回答已采纳
我得到以下类型记录错误：
错误：(34，20) TS2345:类型为'undefined[]‘的参数不能分配给'number not’类型的参数。输入'undefined[]‘不能指定键入'Scheduler’。属性'now‘在'undefined[]’类型中缺失。
在此上下文中使用startWith时：
items$:any = Observable
.interval(250)
.map((_:any) => Math.random())
.startWith([])
浏览 2提问于2016-06-15得票数 0
1回答
我想在我的代码上实现这个，但是在实现它时我有一个问题。
我在实现这一行代码时出错了：
function search(text: string, pipe: PipeTransform): Country[] {
return COUNTRIES.filter(country => {
const term = text.toLowerCase();
return country.name.toLowerCase().includes(term)
|| pipe.transform(country.area).includes(term)
浏览 2提问于2020-03-16得票数 0
回答已采纳
我有多个热的可观察物，它们可能会也可能不会发射粒子。因此，我希望合并这些可观察对象，如果它们中的任何一个发出结果，则处理结果，但如果其他可观察对象发出一个结果，则应将它们一起处理。
例如：
observable1 = PublishSubject<>()
observable2 = PublishSubject<>()
observable1.onNext(1)
observable1.onNext(2)
observable2.onNext("Test")
observable1.onNext(3)
应该发出：
(1, null)
浏览 8提问于2018-01-11得票数 0
回答已采纳
我有一个应用程序，每10秒随机得到笑话。我使用来自rxjs的interval操作符进行倒计时，10秒后，我提出了一个http请求，以得到一个随机的笑话。问题是，我使用异步管道在模板中显示了两次笑话。我知道，这样做将创建两个新的订阅，并提出两次http请求。为了处理这个问题，我尝试使用shareReplay或发布+ refCount，以便只发出一个http请求。但是它两次调用getRandomJoke服务函数。如何解决这个问题。
代码和演示-
random-joke.component.html
<div class="joke-title">{{joke | as
浏览 7提问于2021-07-19得票数 0
回答已采纳
我有一个使用PublishSubject的分页解决方案，如下所示： private val pages: PublishSubject<Int> = PublishSubject.create()
val observable: Observable<List<Data> = pages.hide()
.filter { !inFlight }
.doOnNext { inFlight = true }
.flatMap{
getPage(it) // Returns an
浏览 16提问于2019-10-07得票数 1
回答已采纳
我有一项服务是回报承诺
另一个是投递数据和返回保存的数据。
成功保存后，返回true
所以返回类型的方法应该是Observable<boolean>，而不是Observable<any>，下面是代码
// I want it's return type to be Observable<boolean>
saveUser(record: any): Observable<any> {
return from(this.getUserById(1))
.pipe(concatMap((data
浏览 4提问于2020-02-13得票数 0
1回答
我正在尝试创建一个自动完成程序，为每次输入从API接收数据，现在我每次都显示数据，但是首先，对于每个类型，我总是有这个错误。
您提供了“未定义”的流。您可以提供一个可观察的、许诺的、数组的或可迭代的。
即使我将数据订阅到变量中，也不会发生任何事情。这是错误的处理，您将看到显示的数据。
这是我的app.component.ts
ngOnInit() {
this.results = this.searchText.valueChanges.pipe(
startWith(''),
// delay emits
debounceT
浏览 6提问于2021-04-20得票数 0
1回答
在我的角项目中，我需要在令牌到期之前刷新它，方法是进行用户交互。在UI上，我们显示会话超时消息和更新图标，就在它到期前5分钟，当用户单击更新图标时，我们刷新令牌，现在它使用这个新令牌再次检查会话，等等。
RxJs诉5.1
角V4.0
我正在使用setInterval()和clearInterval()，下面是相关代码
@Compononet({})
export class AdminLayoutComponent implements OnInit {
isRefreshingToken: boolean;
interval: any;
period:
浏览 0提问于2018-08-23得票数 2
回答已采纳
1回答
如何将Observable<News>添加到可观察的数组中？
newsArray: Observable<Array<any>>;
addNews(newsId: number) {
let news = this.newsService.getNewNews(newsId); // this returns a Observable<News> type.
//I want to add `news` to `newsArray` to display it in UI.
}
HTML：
<li *ngFor="le
浏览 0提问于2018-02-08得票数 1
回答已采纳
2回答
我用的是角7，我试着从我的路线上得到数据。
我的懒货路线是这样设置的：
{
data: { menuItems: DASHBOARD_MENU_ITEMS },
path: 'dashboard',
loadChildren: './modules/dashboard/dashboard.module#DashboardModule',
},
{
data: { menuItems: ADMIN_MENU_ITEMS },
path: 'admin',
loadChildren: &#
浏览 4提问于2019-02-26得票数 0
回答已采纳
作为示例，我构建了fiddle (用answer更新) 我喜欢它所做的，但我希望它能触发，如果我只输入input1，然后给我2和3的结果为“空”。 这样的事情可能吗？(在提供的示例中，所有输入都必须有一个值) var obs1 = Rx.Observable.fromEvent(input1, 'input').map((e) => e.target.value);
var obs2 = Rx.Observable.fromEvent(input2, 'input').map((e) => e.target.value);
var obs3 =
浏览 9提问于2019-01-16得票数 1
回答已采纳
我有以下逻辑，用于从completable (使用doOnComplete回调)创建可观察数据，该数据是经过单元测试的：
class ObservableSrc(val completableSrc: CompletableSrc) {
fun getObservable(client: Client): Observable<State> {
return client.getResults()
.concatMap { processResult(client, it.values) }
}
private f
浏览 2提问于2019-01-02得票数 2
我有以下可观察到的：
observable1
.withLatestFrom(observable2) { (obs1Value, obj2Value) -> [SomeDataType] in
return obj1Value.someFunction(for: obj2Value)
}
.bind(to: someSubject)
.disposed(by: disposeBag)
当以下PublishRelay触发时，应该更新它：
let publishRelay = PublishRelay<AnotherDataType&g
浏览 16提问于2022-10-26得票数 1
回答已采纳
我正在尝试以固定的时间间隔合并两个传感器数据流，但在Rx中无法正确完成此操作。我想出的最好的例子是下面的例子，但是我怀疑这是Rx的最佳使用。
有没有更好的方法？
我尝试过Sample()，但传感器以不规则的间隔产生值，慢(>1秒)和快(<1秒)。Sample()似乎只处理快速数据。
Observable<SensorA> sensorA = ... /* hot */
Observable<SensorB> sensorB = ... /* hot */
SensorA lastKnownSensorA;
SensorB lastKnownSensorB;
浏览 0提问于2015-01-29得票数 3
我已经建立了一部史诗，等待另一部史诗的完成，就像@jayphelps在这里的回答：
然而，我发现它似乎只运行了一次。在此之后，我可以在控制台中看到CART_CONFIG_READY操作，但不会触发DO_THE_NEXT_THING操作。
我尝试过mergeMap和switchMap的各种组合，有和没有take，但似乎没有任何帮助。
这就是我的代码看起来的样子。
import { NgRedux } from '@angular-redux/store';
import { Observable } from 'rxjs/Observable';
import {
浏览 3提问于2017-09-27得票数 2
回答已采纳
我刚接触到角，我正在尝试获取一个本地api (localhost:4200/office_keys)，以便以这种方式显示垫子上的项--自动完成：
HTML:
<mat-form-field appearance="outline">
<mat-label>Office Key</mat-label>
<input matInput [formControl]="control" [matAutocomplete]="office_keys" #desc requi
浏览 2提问于2022-03-07得票数 1
回答已采纳
3回答
我是新来的。我实现了material，其中我从服务加载数据并调用组件，如下所示：
ngOnInit() {
this.UsuariosService.getUser().subscribe(results => {
if (!results) {
return;
}
this.dataSource = new MatTableDataSource(results);
this.dataSource.sort = this.sort;
this.dataSource.paginator = this.pa
浏览 0提问于2018-06-12得票数 1
回答已采纳
3回答
我创建了一个身份验证服务，组件可以订阅权限更改(登录/注销/角色更改等)。在isAuthenticated函数中，我返回一个主题。问题是我想用一个值返回主题(比如Observable.of )。现在，我正在使用setTimeout。
@Injectable()
export class AuthenticationService {
constructor(private credentials: CredantialsStorageService,
private oauthService:OAuth2Service,
private secureHttp: Secu
浏览 4提问于2017-07-30得票数 3
回答已采纳
我正在尝试实现多个术语的搜索。N
我读到了这个博客： it相似的案例。但我不明白如何使用动态观察值(搜索词输入)来实现它。假设我有30个搜索词的过滤器。简单的解决方案是使用combineLatest到所有的搜索词组件，但效率不高。我的目标是在第一次更改时订阅可观察对象。
我尝试对动态数组使用combineLatest运算符，但它不起作用：(。
我的代码：
import {Component, OnInit, Input, ViewChildren, QueryList, AfterViewInit} from '@angular/core';
import {Table}
浏览 2提问于2017-06-19得票数 0
下面是一个代码示例，它为我提供每30秒一次的结果(30秒)，但是，当组件订阅该服务时，还必须等待30秒才能获得初始数据集：
getTasks(query: string): Observable<any> {
return this._http.get(this._ripcord + '/tasks' + query, this.getHttpOptions())
.map((response: Response) => <any>response.json())
.delay(30000)
.repeat()
浏览 7提问于2017-12-11得票数 0
回答已采纳
1回答
我很难将可观测A的结果绑定到一个可以观察到的B上，这样：
Rx.Observable.concat(
A,
A.bind(valuesInA =>
B.scan((acc, value) => {
acc.push(value);
return acc;
}, valuesInA)))
例如，如果是这样的话：
A: { onNext:[monkey], onComplete }
B: { onNext:banana, onNext:tree, onNext: ... }
我想让大家注意到：
AB: { onNext:[monkey],
浏览 4提问于2015-09-03得票数 1
回答已采纳
编辑：请注意，正如丹尼尔和拉特金在下面的回答和评论中所指出的，这个问题涉及到F#中的一个bug，这个问题似乎在2014年初就已经解决了。
我正试图为Observable.StartWith编写一个咖喱包装器。我使用的是预发布的反应性扩展2.0和VS11测试版。我想要的结果是startWith : 'a -> IObservable<'a> -> IObservable<'a>。显而易见的实现是这样的：
let startWith
(value : 'a)
(observable : IObs
浏览 2提问于2012-06-17得票数 2
回答已采纳
1回答
有一个websocket回送服务，用于发送和接收消息：
@Injectable()
export class NotificationsService {
private ws = new $WebSocket('wss://echo.websocket.org');
wsSendMessage(message: string = `Message ${Math.random()}`): void {
this.ws.send(message);
}
wsGetMessages(): Observable<string> {
re
浏览 1提问于2016-07-21得票数 1
回答已采纳
1回答
我试图创建一个表单，仅发送视图，它有一个SignaturePad，一旦用户单击保存按钮，一个保存意图就会被触发，并做一些后台处理。
我有以下几点：
主持人：
@Override
protected void bindIntents() {
Observable<SignatureViewState> observable =
intent(SignatureView::saveSignature)
.switchMap(intent -> Observable.fromCa
浏览 0提问于2017-06-20得票数 0
回答已采纳
当应用程序.I出现错误时，我试图显示错误组件，使interceptor检查是否有错误是服务响应。如果是，它将重定向到error组件，但目前它没有重定向为什么这里是我的代码
import { Injectable } from '@angular/core';
import { HttpEvent, HttpErrorResponse, HttpInterceptor, HttpHandler, HttpRequest } from '@angular/common/http';
import { Router } from '@angular/route
浏览 1提问于2018-08-27得票数 1
回答已采纳
假设我有一个异步方法，它运行一个查询并返回一组结果：
Task<IEnumerable<Foo>> FetchResultSet();
我有一个观察值，每当需要再次获取结果集时都会触发：
IObservable<Unit> NeedToRefetch;
我想要的是：
IObservable<IEnumerable<Foo>>
这将(1)运行查询并生成初始结果集，以及(2)每次触发NeedToRefetch时，再次运行查询并生成另一个结果集。
组成这个可观察对象的最好方法是什么？
如果我不需要初始结果集，我可以这样做：
NeedToRe
浏览 0提问于2016-12-18得票数 3
我遇到了一个问题，下面的代码不能用kotlin编译。
// StateModel.kt
sealed class StateModel
class Loading : StateModel()
data class Success<T: Any>(val data: T) : StateModel()
data class MyError(val message: String) : StateModel()
// StateModelTransformer.kt
class StateModelTransformer<T: Any> : FlowableTransf
浏览 1提问于2017-08-04得票数 3
回答已采纳
我有个副作用看起来是这样的：
@Effect()
loadAll$: Observable<Action> = this.actions$
.ofType(reservationsActions.LOAD_ALL)
.startWith(new reservationsActions.LoadAll())
.switchMap(() =>
this.reservationsService.index()
.map((reservations: Reservation[]) => new reservationsActions.LoadAllS
浏览 4提问于2017-08-18得票数 1
1回答
我有一个CoreLocation管理器，它应该通过RxSwift (及其扩展和DelegateProxies)提供可观察的属性来处理所有的CLLocationManager。LocationRepository看起来是这样的：
class LocationRepository {
static let sharedInstance = LocationRepository()
var locationManager: CLLocationManager = CLLocationManager()
private (set) var supportsRequiredLoc
浏览 2提问于2017-01-24得票数 0
回答已采纳
3回答
角度可观测滤波
、、、
我遇到了一个用数组过滤可观察到的问题。让我解释一下..。
我有：
产品$：可观察；
过滤产品$：可观察；
selectedFilters =[“filter的名称”，idOfFilter，“filter的名称”，idOfFilter]；(开头为空)
以下是产品对象的结构：
这是我的过滤器阵列的结构
我想将过滤的结果设置为filteredProducts。对于filter，我必须检查产品的filter数组是否包含过滤器的名称，以及产品值数组的filter id是否包含。
到目前为止我一直在写这篇文章，但我不知道如何过滤我的可观察到的.
export class P
浏览 0提问于2020-05-17得票数 0
this.filteredContact = this.contactControl.valueChanges.pipe(
startWith(''),
debounceTime(200),
map(val => this.filterContact(val))
);
filterContact(val: string): any {
if (val.length > 2) {
return _.filter(
this.contacts,
item => item.name.toLowerCase().i
浏览 0提问于2018-04-12得票数 1
回答已采纳
我对rxjs还是个新手，我想出的这个例子感觉不是很优雅。从本质上讲，我如何才能将3个截然不同的可观察对象组合成一个呢？你能像网上展示的许多例子一样，用高阶函数的风格来做吗？ createFilteredDataObservable(initialData: Observable<Data[]>,
valueSource: Observable<any>,
clickSource: Subject<boolean>): Observable&
浏览 12提问于2019-05-08得票数 1
回答已采纳
2回答
我正在用最新的角度材料编写一个angular6应用程序.
我将组件mat-autocomplete与mat-input一起用于自动完成功能。
我试图实现的是，当用户专注于输入元素时，他将看到所有可用的自动完成选项，即使没有输入任何内容。
这是mat自动完成组件的html文件：
<form [formGroup]="carTypeFormGroup" (ngSubmit)="okButton()">
<mat-form-field>
<input matInput formControlName="carCompa
浏览 0提问于2018-09-27得票数 7
回答已采纳
1回答
如何订阅可观察到的副作用？
、、、、
我有一个方法，它调用另一个服务来播放播放器中的流url。playStream$()返回一些流数据，这些数据也应该从play$()方法返回。作为播放流的一个副作用，我想发送一个由间隔触发的心跳。
play$(streamId: number, position?: number): Observable<Stream> {
return this.playerService.playStream$(streamId, position)
.pipe(
tap(() => this.heartbeat$(streamId).subscribe())
浏览 5提问于2022-01-26得票数 1
在一个角度应用程序中，我从数据库中加载数据，使用
data.service.ts
import {Injectable} from '@angular/core';
import {Post} from '../Post';
import {Observable, of} from 'rxjs';
import { HttpClient } from '@angular/common/http';
@Injectable()
export class DataService {
constructor(private http
浏览 0提问于2018-10-30得票数 2
1回答
我正在尝试使用异步管道将可观察到的流直接实现到我的模板中，并且处理代码中描述的错误如下所示：
export class MyClass {
private myData$: Observable<any>;
private hasError$: Observable<boolean>;
constructor(private shared: SharedService) {
this.myData$ = this.shared.data$;
this.hasError$ = this.myData$.catch(err => Obse
浏览 0提问于2018-04-26得票数 0
回答已采纳
2回答
我有一个定时器(触发可观察的)-我在服务构造函数中找到了它。假设它每10秒获取一次数据(代码是手工复制的，而不是复制粘贴的，所以请原谅我有任何输入)：
@Injectable({
provideIn: "root",
})
export class myService {
isGetFullData: boolean;
subscription: Subscription;
myDataSubject = new Subject<any>;
myDataSubjectChanged : Observable<any> = this.m
浏览 0提问于2020-07-06得票数 1
因此，ng服务和ng build编译和运行都没有错误。当我运行ng build prod时，它告诉我属性'title‘在类型'{}’上不存在。我也厌倦了实现一个接口，并且得到了同样的错误。代码运行得很好，使用ng serve时没有任何错误。
`<div class="row">
<div class="col-md-6">
<form #f="ngForm" (ngSubmit)="save(f.value)">
<div class="fo
浏览 1提问于2018-05-27得票数 0
3回答
你好，我每15秒向我的服务器询问它的在线/离线状态：
public Observable<Response> repeatCheckServerStatus(int intervalSec, final String path) {
return Observable.interval(intervalSec, TimeUnit.SECONDS)
.flatMap(new Func1<Long, Observable<Response>>() {
@Override
浏览 4提问于2016-01-23得票数 16
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
