Server IP : 150.95.80.236 / Your IP : 3.16.69.52 Web Server : Apache System : Linux host-150-95-80-236 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : social-telecare ( 10000) PHP Version : 7.4.33 Disable Function : opcache_get_status MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/vhosts/pcu.in.th/api-uat.pcu.in.th/node_modules/rxjs/dist/esm5/internal/operators/ |
Upload File : |
import { __values } from "tslib"; import { EMPTY } from '../observable/empty'; import { operate } from '../util/lift'; import { createOperatorSubscriber } from './OperatorSubscriber'; export function takeLast(count) { return count <= 0 ? function () { return EMPTY; } : operate(function (source, subscriber) { var buffer = []; source.subscribe(createOperatorSubscriber(subscriber, function (value) { buffer.push(value); count < buffer.length && buffer.shift(); }, function () { var e_1, _a; try { for (var buffer_1 = __values(buffer), buffer_1_1 = buffer_1.next(); !buffer_1_1.done; buffer_1_1 = buffer_1.next()) { var value = buffer_1_1.value; subscriber.next(value); } } catch (e_1_1) { e_1 = { error: e_1_1 }; } finally { try { if (buffer_1_1 && !buffer_1_1.done && (_a = buffer_1.return)) _a.call(buffer_1); } finally { if (e_1) throw e_1.error; } } subscriber.complete(); }, undefined, function () { buffer = null; })); }); } //# sourceMappingURL=takeLast.js.map