|
@@ -119,8 +119,11 @@ export class StreamService {
|
|
|
* stream core push with block stream
|
|
|
* @param stream meta Json and stream
|
|
|
*/
|
|
|
+ pushFrameToSteam: Promise<StreamPushResponse> = seqExeAsyncFn(
|
|
|
+ this.pushFrameToSteamFn,
|
|
|
+ ) as any as Promise<StreamPushResponse>;
|
|
|
|
|
|
- pushFrameToSteam(stream: StreamFrameType): Promise<StreamPushResponse> {
|
|
|
+ pushFrameToSteamFn(stream: StreamFrameType): Promise<StreamPushResponse> {
|
|
|
return new Promise(async (resolve, reject) => {
|
|
|
try {
|
|
|
// let start, stop;
|