调用delay后调用next报错：类型'Observable<{}>'无'next'属性

嘿，我来帮你理清楚这个问题——你遇到的错误本质是对RxJS里的Observable和Subject的API理解有点偏差啦。

为什么会报错？ #

不管你用new Observable()还是new Subject()，当你调用.delay(3000)的时候，这个操作符会返回一个全新的Observable实例，而不是原来的那个Subject/Observable。关键点在于：

• next()是Observer或者Subject（因为Subject同时兼具Observable和Observer的身份）才有的方法，用来手动推送数据
• 但delay()返回的普通Observable是没有next()方法的，它只是一个可以被订阅的数据流，没法手动推送数据

正确的写法有两种，看你的需求选： #

1. 如果你需要手动多次推送数据（用Subject的场景）

你得先对Subject的数据流应用delay操作符，然后再调用Subject本身的next()——因为next()是Subject的方法，不是delay返回的Observable的方法：

import { Subject } from 'rxjs';
import { delay } from 'rxjs/operators';

// 创建Subject实例
const o = new Subject();

// 先对Subject的数据流加上delay操作符，然后订阅
o.pipe(delay(3000)).subscribe(data => {
  console.log('收到延迟后的数据:', data); // 3秒后才会输出
});

// 调用Subject的next推送数据，这个数据会经过delay延迟后到达订阅者
o.next({ stuff: '你的数据内容' });
// 之后还可以继续调用next推送其他数据，都会被延迟3秒
// o.next({ other: '更多数据' });

2. 如果只是单次延迟推送数据（不需要手动控制多次发送）

直接用of配合delay，或者timer会更简单，根本不需要Subject：

import { of } from 'rxjs';
import { delay } from 'rxjs/operators';

// 创建一个会延迟3秒后发送指定数据的Observable
of({ stuff: '你的数据内容' })
  .pipe(delay(3000))
  .subscribe(data => {
    console.log('收到延迟后的数据:', data);
  });

或者用timer的写法：

import { timer } from 'rxjs';
import { map } from 'rxjs/operators';

// timer(3000)会在3秒后发送一个0，我们把它转换成需要的数据
timer(3000)
  .pipe(map(() => ({ stuff: '你的数据内容' })))
  .subscribe(data => {
    console.log('收到延迟后的数据:', data);
  });

最后再划个重点 #

记住：RxJS的操作符（比如delay）都是返回新的Observable，不会修改原来的源对象。所以你不能在操作符返回的Observable上调用next()，要在原来的Subject上调用，操作符只是处理数据流的传递~

内容的提问来源于stack exchange，提问作者Pascal