javascript - 设置 RxJs 订阅后,是否有一种干净的方法可以立即执行函数?
问题描述
我想做的事:
- 向 websocket 服务器发送“请求”事件。
- 接收包含一些附加数据的即时响应事件。
- 随着时间的推移不断收到回复。
我的问题是:
- 有没有更清洁的方法来做我在下面做的事情?不使用 setTimeout。
首先,看看这个简化的工作示例:
const { Subject, defer, interval, of} = rxjs;
const EventEmitter = EventEmitter3;
const emitter = new EventEmitter();
const subject = new Subject();
// The next lines mock a websocket server message listener, imagine this being present on server side
emitter.on("request", () => {
subject.next(`Immediate response`);
interval(1000).subscribe((index) =>
subject.next(`Delayed response...${index}`)
);
});
// Imagine the following code being present in the browser
function getData() {
return defer(() => {
// The next line mocks a websocket client sent event
setTimeout(() => emitter.emit("request"), 0);
return subject;
});
}
getData().subscribe((data) => console.log(data));
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.5.3/rxjs.umd.min.js"></script>
<script src="https://unpkg.com/eventemitter3@latest/umd/eventemitter3.min.js"></script>
现在看一个不工作的例子。在这里,客户端没有得到立即响应,因为“请求”事件是在订阅设置之前发送的。
const { Subject, defer, interval, of} = rxjs;
const EventEmitter = EventEmitter3;
const emitter = new EventEmitter();
const subject = new Subject();
// The next lines mock a websocket server message listener, imagine this being present on server side
emitter.on("request", () => {
subject.next(`Immediate response`);
interval(1000).subscribe((index) =>
subject.next(`Delayed response...${index}`)
);
});
// Imagine the following code being present in the browser
function getData() {
return defer(() => {
emitter.emit('request');
return subject;
});
}
getData().subscribe((data) => console.log(data));
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.5.3/rxjs.umd.min.js"></script>
<script src="https://unpkg.com/eventemitter3@latest/umd/eventemitter3.min.js"></script>
解决方案
您可以使用 aBehaviorSubject
而不是 a Subject
:
const { BehaviorSubject, defer, interval, of } = rxjs;
const EventEmitter = EventEmitter3;
const emitter = new EventEmitter();
const subject = new BehaviorSubject();
// The next lines mock a websocket server message listener, imagine this being present on server side
emitter.on("request", () => {
// the timing of this synchronous response would be impossible in a real socket
subject.next(`Immediate response`);
interval(1000).subscribe((index) =>
subject.next(`Delayed response...${index}`)
);
});
// Imagine the following code being present in the browser
function getData() {
return defer(() => {
emitter.emit('request');
return subject;
});
}
getData().subscribe((data) => console.log(data));
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.5.3/rxjs.umd.min.js"></script>
<script src="https://unpkg.com/eventemitter3@latest/umd/eventemitter3.min.js"></script>
请记住,尽管在发送套接字请求后服务器的响应不可能同步返回,就像您为此演示实现模拟的方式一样,所以虽然Subject
这里不会产生预期的结果,但它可以正常工作一个真正的插座。
推荐阅读
- php - 编辑特定产品
- angular - 如何在ionic 3中选择多个图像和视频
- php - php htaccess 重写失败
- vba - 在 Powerpoint 上的固定位置之间同时进行多形状旋转
- c# - 如何统一分配随机颜色?
- node.js - 如何检查mysql连接是否有效
- javascript - IONIC 5 / Angular 9 在原生构建中延迟加载特定组件
- sql - Oracle SQL - WHERE 子句
- swift - 如何为 UIViewController.view 中也具有 UITapGestureRecognizer 的 UIView 挑选和操作 UITapGestureRecognizer?
- azure - 创建具有受限权限的 kubeconfig