Neo4j MCP Server

import { Observable } from '../Observable'; export function scheduleArray(input, scheduler) { return new Observable((subscriber) => { let i = 0; return scheduler.schedule(function () { if (i === input.length) { subscriber.complete(); } else { subscriber.next(input[i++]); if (!subscriber.closed) { this.schedule(); } } }); }); } //# sourceMappingURL=scheduleArray.js.map