使用RxJS 6.x WebSocketSubject客户端

Question

使用RxJS 6.x WebSocketSubject客户端

我无法弄清楚如何在rxjs中使用WebSocketSubjects v6.x

这是工作的HTML/JS v5.5.6.注释掉的代码是我试图让它在v6.x以下工作:

<html>
<head>
    <!-- <script src="https://unpkg.com/@reactivex/rxjs@6.0.0/dist/global/rxjs.umd.js"></script> -->
    <script src="https://unpkg.com/@reactivex/rxjs@5.5.6/dist/global/Rx.js"></script>
    <script>
        // const { WebSocketSubject } = rxjs.webSocket;
        // const socket$ = WebSocketSubject.create('ws://localhost:8080');
        const socket$ = Rx.Observable.webSocket('ws://localhost:8080');
        socket$.subscribe(
                (data) => console.log(data),
                (err) => console.error(err),
                () => console.warn('Completed!')
            );
        socket$.next(JSON.stringify({
            event: 'events',
            data: 'test',
        }));
        console.log('here')
    </script>
</head>
<body></body>
</html>

Run Code Online (Sandbox Code Playgroud)

Answer 1

Cor*_*ole 7

我得到了它rxjs@6.1.0.我怀疑,我只是使用版本6语法错误.见工作示例:

<html>

<head>
    <script src="https://unpkg.com/@reactivex/rxjs@6.1.0/dist/global/rxjs.umd.js"></script>
    <script>
        const { WebSocketSubject } = rxjs.webSocket;
        const socket$ = new WebSocketSubject('ws://localhost:8080');
        socket$.subscribe(
            (data) => console.log(data),
            (err) => console.error(err),
            () => console.warn('Completed!')
        );
        socket$.next({
            event: 'events',
            data: 'test',
        });
        console.log('here')
    </script>
</head>

<body></body>

</html>

Run Code Online (Sandbox Code Playgroud)

归档时间：	7 年，8 月前
查看次数：	5315 次
最近记录：	7 年，1 月前