graphql-subscriptions/dist/with-filter.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var iterall_1 = require("iterall");
exports.withFilter = function (asyncIterator, filterFn) {
    return function (rootValue, args, context, info) {
        var getNextPromise = function () {
            return asyncIterator
                .next()
                .then(function (payload) { return Promise.all([
                payload,
                Promise.resolve(filterFn(payload.value, args, context, info)).catch(function () { return false; }),
            ]); })
                .then(function (_a) {
                var payload = _a[0], filterResult = _a[1];
                if (filterResult === true) {
                    return payload;
                }
                return getNextPromise();
            });
        };
        return _a = {
                next: function () {
                    return getNextPromise();
                },
                return: function () {
                    return Promise.resolve({ value: undefined, done: true });
                },
                throw: function (error) {
                    return Promise.reject(error);
                }
            },
            _a[iterall_1.$$asyncIterator] = function () {
                return this;
            },
            _a;
        var _a;
    };
};
//# sourceMappingURL=with-filter.js.map