Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 | 4x 4x 15x 15x 4x 185x 4x 34x 23x 11x 34x 4x 132x | import Stream from "./stream";
import { StreamSubscriptionActions } from "./stream_subscription";
import {
StreamMessageError,
StreamMessageData,
StreamMessageType,
StreamMessageDone,
} from "./types";
/** @ignore utility for handling promises: cancels subscription and (resolve | rejects) the value */
export const cancelAndFulfill = function (
v: any,
sub: StreamSubscriptionActions,
fulfill: (v: any) => void
) {
sub.cancel();
fulfill(v);
};
/** @ignore utility for running a function on the next tick **/
/* istanbul ignore next*/
export const nextTick = function (fn: () => any) {
const nextTick = global?.process?.nextTick || Promise.resolve().then;
nextTick(fn);
};
/** @ignore utility for creating a *data* StreamMessage **/
export const createDataMessage = function <T>(data: T): StreamMessageData<T> {
return { type: StreamMessageType.Data, data };
};
/** @ignore utility for creating an *error* StreamMessage **/
export const createErrorMessage = function (
m: string | Error
): StreamMessageError {
let err;
if (typeof m === "string") {
err = new Error(m);
} else {
err = m;
}
return { type: StreamMessageType.Error, data: err };
};
/** @ignore utility for creating a *done* StreamMessage **/
export const createDoneMessage = function (): StreamMessageDone {
return { type: StreamMessageType.Done };
};
|