| 1 | ;
|
| 2 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 3 | const buffer_1 = require("../buffer");
|
| 4 | function buffer(count, skip) {
|
| 5 | if (skip == null) {
|
| 6 | skip = count;
|
| 7 | }
|
| 8 | return function bufferOperatorFunction(source) {
|
| 9 | return new buffer_1.BufferAsyncIterable(source, count, skip);
|
| 10 | };
|
| 11 | }
|
| 12 | exports.buffer = buffer;
|
| 13 |
|
| 14 | //# sourceMappingURL=data:application/json;charset=utf8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbImFzeW5jaXRlcmFibGUvcGlwZS9idWZmZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7QUFFQSxzQ0FBZ0Q7QUFFaEQsU0FBZ0IsTUFBTSxDQUNwQixLQUFhLEVBQ2IsSUFBYTtJQUViLElBQUksSUFBSSxJQUFJLElBQUksRUFBRTtRQUNoQixJQUFJLEdBQUcsS0FBSyxDQUFDO0tBQ2Q7SUFDRCxPQUFPLFNBQVMsc0JBQXNCLENBQ3BDLE1BQThCO1FBRTlCLE9BQU8sSUFBSSw0QkFBbUIsQ0FBVSxNQUFNLEVBQUUsS0FBSyxFQUFFLElBQUssQ0FBQyxDQUFDO0lBQ2hFLENBQUMsQ0FBQztBQUNKLENBQUM7QUFaRCx3QkFZQyIsImZpbGUiOiJhc3luY2l0ZXJhYmxlL3BpcGUvYnVmZmVyLmpzIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgT3BlcmF0b3JBc3luY0Z1bmN0aW9uIH0gZnJvbSAnLi4vLi4vaW50ZXJmYWNlcyc7XG5pbXBvcnQgeyBBc3luY0l0ZXJhYmxlWCB9IGZyb20gJy4uLy4uL2FzeW5jaXRlcmFibGUvYXN5bmNpdGVyYWJsZXgnO1xuaW1wb3J0IHsgQnVmZmVyQXN5bmNJdGVyYWJsZSB9IGZyb20gJy4uL2J1ZmZlcic7XG5cbmV4cG9ydCBmdW5jdGlvbiBidWZmZXI8VFNvdXJjZT4oXG4gIGNvdW50OiBudW1iZXIsXG4gIHNraXA/OiBudW1iZXJcbik6IE9wZXJhdG9yQXN5bmNGdW5jdGlvbjxUU291cmNlLCBUU291cmNlW10+IHtcbiAgaWYgKHNraXAgPT0gbnVsbCkge1xuICAgIHNraXAgPSBjb3VudDtcbiAgfVxuICByZXR1cm4gZnVuY3Rpb24gYnVmZmVyT3BlcmF0b3JGdW5jdGlvbihcbiAgICBzb3VyY2U6IEFzeW5jSXRlcmFibGU8VFNvdXJjZT5cbiAgKTogQXN5bmNJdGVyYWJsZVg8VFNvdXJjZVtdPiB7XG4gICAgcmV0dXJuIG5ldyBCdWZmZXJBc3luY0l0ZXJhYmxlPFRTb3VyY2U+KHNvdXJjZSwgY291bnQsIHNraXAhKTtcbiAgfTtcbn1cbiJdfQ==
|