@cloudpss/message-stream

Message stream type definitions for cloudpss APIs. And plugin for @cloudpss/http-client, provides cloudpss message stream APIs.

Example

``ts
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);
``