Function createReadable

src/push.js:642–673

* Create the readable async iterable from a queue.

(queue)

 * Create the readable async iterable from a queue.
 */
function createReadable(queue) {
    var _a;
    return _a = {},
        _a[Symbol.asyncIterator] = function () {
            return {
                next: function () {
                    return __awaiter(this, void 0, void 0, function () {
                        return __generator(this, function (_a) {
                            return [2 /*return*/, queue.read()];
                        });
                    });
                },
                return: function () {
                    return __awaiter(this, void 0, void 0, function () {
                        return __generator(this, function (_a) {
                            queue.consumerReturn();
                            return [2 /*return*/, { value: undefined, done: true }];
                        });
                    });
                },
                throw: function (error) {
                    return __awaiter(this, void 0, void 0, function () {
                        return __generator(this, function (_a) {
                            queue.consumerThrow(error);
                            return [2 /*return*/, { value: undefined, done: true }];
                        });
                    });
                },
            };
        },
        _a;
}
// =============================================================================
// Stream.push() Factory
// =============================================================================