0.5.30 • Published 20 days ago
@cloudpss/message-stream-plugin v0.5.30
@cloudpss/message-stream-plugin
Message stream plugin for @cloudpss/http-client
, provides cloudpss message stream APIs.
Example
import { HttpClient } from '@cloudpss/http-client';
import { MessageStreamPlugin } from '@cloudpss/message-stream-plugin';
import { interval } from 'rxjs';
import { map, take } from 'rxjs/operators';
const http = new HttpClient({
/* config */
}).use(MessageStreamPlugin());
const stream = await http.stream.create({ type: 'object', comment: 'test', durability: 0 });
await http.stream.write(
stream.token,
stream.type,
interval(100)
.pipe(take(10))
.pipe(map((i) => ({ i }))),
);
await http.stream.freeze(stream.token);
0.5.30
20 days ago
0.5.29
1 month ago
0.5.28
2 months ago
0.5.26
2 months ago
0.5.25
2 months ago
0.5.24
2 months ago
0.5.23
2 months ago
0.5.22
2 months ago
0.5.21
2 months ago
0.5.18
2 months ago
0.5.19
2 months ago
0.5.20
2 months ago
0.5.17
3 months ago
0.5.16
4 months ago
0.5.14
4 months ago
0.5.15
4 months ago
0.5.13
4 months ago
0.5.12
5 months ago
0.5.11
5 months ago
0.5.10
5 months ago
0.5.8
5 months ago
0.5.9
5 months ago
0.4.31
10 months ago
0.4.32
9 months ago
0.4.30
10 months ago
0.4.28
10 months ago
0.4.29
10 months ago
0.4.27
11 months ago
0.4.35
8 months ago
0.4.33
9 months ago
0.4.34
9 months ago
0.5.3
6 months ago
0.5.6
6 months ago
0.5.0
7 months ago
0.5.2
6 months ago
0.5.1
6 months ago
0.4.26
11 months ago
0.4.24
11 months ago
0.4.25
11 months ago
0.4.23
12 months ago
0.4.22
12 months ago
0.4.21
12 months ago