diff options
| author | Danijel Andjelkovic <adanijel99@gmail.com> | 2022-03-01 21:54:41 +0100 | 
|---|---|---|
| committer | Danijel Andjelkovic <adanijel99@gmail.com> | 2022-03-01 21:54:41 +0100 | 
| commit | 6c8128f9fd5a5d0be115806c35a21b3d683df8d6 (patch) | |
| tree | f46c2f6b3b9b294ff32bd75c08ccdc9e7a8cc4ef /sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing | |
| parent | 2400b84e95913665da6279114168148444b8f9ab (diff) | |
| parent | 7d3640f824f46490b47bd95f1c5a16644f712068 (diff) | |
Merge branch 'dev' of http://gitlab.pmf.kg.ac.rs/igrannonica/neuronstellar into logo
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing')
12 files changed, 416 insertions, 0 deletions
| diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/ColdObservable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/ColdObservable.js new file mode 100644 index 00000000..4bb51733 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/ColdObservable.js @@ -0,0 +1,30 @@ +import { Observable } from '../Observable'; +import { Subscription } from '../Subscription'; +import { SubscriptionLoggable } from './SubscriptionLoggable'; +import { applyMixins } from '../util/applyMixins'; +export class ColdObservable extends Observable { +    constructor(messages, scheduler) { +        super(function (subscriber) { +            const observable = this; +            const index = observable.logSubscribedFrame(); +            const subscription = new Subscription(); +            subscription.add(new Subscription(() => { +                observable.logUnsubscribedFrame(index); +            })); +            observable.scheduleMessages(subscriber); +            return subscription; +        }); +        this.messages = messages; +        this.subscriptions = []; +        this.scheduler = scheduler; +    } +    scheduleMessages(subscriber) { +        const messagesLength = this.messages.length; +        for (let i = 0; i < messagesLength; i++) { +            const message = this.messages[i]; +            subscriber.add(this.scheduler.schedule(({ message, subscriber }) => { message.notification.observe(subscriber); }, message.frame, { message, subscriber })); +        } +    } +} +applyMixins(ColdObservable, [SubscriptionLoggable]); +//# sourceMappingURL=ColdObservable.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/ColdObservable.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/ColdObservable.js.map new file mode 100644 index 00000000..a6f9c6d8 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/ColdObservable.js.map @@ -0,0 +1 @@ +{"version":3,"file":"ColdObservable.js","sources":["../../../src/internal/testing/ColdObservable.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAC3C,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAI/C,OAAO,EAAE,oBAAoB,EAAE,MAAM,wBAAwB,CAAC;AAC9D,OAAO,EAAE,WAAW,EAAE,MAAM,qBAAqB,CAAC;AAQlD,MAAM,OAAO,cAAkB,SAAQ,UAAa;IAMlD,YAAmB,QAAuB,EAC9B,SAAoB;QAC9B,KAAK,CAAC,UAA+B,UAA2B;YAC9D,MAAM,UAAU,GAAsB,IAAW,CAAC;YAClD,MAAM,KAAK,GAAG,UAAU,CAAC,kBAAkB,EAAE,CAAC;YAC9C,MAAM,YAAY,GAAG,IAAI,YAAY,EAAE,CAAC;YACxC,YAAY,CAAC,GAAG,CAAC,IAAI,YAAY,CAAC,GAAG,EAAE;gBACrC,UAAU,CAAC,oBAAoB,CAAC,KAAK,CAAC,CAAC;YACzC,CAAC,CAAC,CAAC,CAAC;YACJ,UAAU,CAAC,gBAAgB,CAAC,UAAU,CAAC,CAAC;YACxC,OAAO,YAAY,CAAC;QACtB,CAAC,CAAC,CAAC;QAXc,aAAQ,GAAR,QAAQ,CAAe;QALnC,kBAAa,GAAsB,EAAE,CAAC;QAiB3C,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;IAC7B,CAAC;IAED,gBAAgB,CAAC,UAA2B;QAC1C,MAAM,cAAc,GAAG,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC;QAC5C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,cAAc,EAAE,CAAC,EAAE,EAAE;YACvC,MAAM,OAAO,GAAG,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC;YACjC,UAAU,CAAC,GAAG,CACZ,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC,EAAE,OAAO,EAAE,UAAU,EAAE,EAAE,EAAE,GAAG,OAAO,CAAC,YAAY,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,EAChG,OAAO,CAAC,KAAK,EACb,EAAE,OAAO,EAAE,UAAU,EAAE,CAAC,CAC3B,CAAC;SACH;IACH,CAAC;CACF;AACD,WAAW,CAAC,cAAc,EAAE,CAAC,oBAAoB,CAAC,CAAC,CAAC"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js new file mode 100644 index 00000000..e2ac7630 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js @@ -0,0 +1,34 @@ +import { Subject } from '../Subject'; +import { Subscription } from '../Subscription'; +import { SubscriptionLoggable } from './SubscriptionLoggable'; +import { applyMixins } from '../util/applyMixins'; +export class HotObservable extends Subject { +    constructor(messages, scheduler) { +        super(); +        this.messages = messages; +        this.subscriptions = []; +        this.scheduler = scheduler; +    } +    _subscribe(subscriber) { +        const subject = this; +        const index = subject.logSubscribedFrame(); +        const subscription = new Subscription(); +        subscription.add(new Subscription(() => { +            subject.logUnsubscribedFrame(index); +        })); +        subscription.add(super._subscribe(subscriber)); +        return subscription; +    } +    setup() { +        const subject = this; +        const messagesLength = subject.messages.length; +        for (var i = 0; i < messagesLength; i++) { +            (() => { +                var message = subject.messages[i]; +                subject.scheduler.schedule(() => { message.notification.observe(subject); }, message.frame); +            })(); +        } +    } +} +applyMixins(HotObservable, [SubscriptionLoggable]); +//# sourceMappingURL=HotObservable.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js.map new file mode 100644 index 00000000..ac44f2af --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js.map @@ -0,0 +1 @@ +{"version":3,"file":"HotObservable.js","sources":["../../../src/internal/testing/HotObservable.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,OAAO,EAAE,MAAM,YAAY,CAAC;AAErC,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAI/C,OAAO,EAAE,oBAAoB,EAAE,MAAM,wBAAwB,CAAC;AAC9D,OAAO,EAAE,WAAW,EAAE,MAAM,qBAAqB,CAAC;AAOlD,MAAM,OAAO,aAAiB,SAAQ,OAAU;IAM9C,YAAmB,QAAuB,EAC9B,SAAoB;QAC9B,KAAK,EAAE,CAAC;QAFS,aAAQ,GAAR,QAAQ,CAAe;QALnC,kBAAa,GAAsB,EAAE,CAAC;QAQ3C,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;IAC7B,CAAC;IAGD,UAAU,CAAC,UAA2B;QACpC,MAAM,OAAO,GAAqB,IAAI,CAAC;QACvC,MAAM,KAAK,GAAG,OAAO,CAAC,kBAAkB,EAAE,CAAC;QAC3C,MAAM,YAAY,GAAG,IAAI,YAAY,EAAE,CAAC;QACxC,YAAY,CAAC,GAAG,CAAC,IAAI,YAAY,CAAC,GAAG,EAAE;YACrC,OAAO,CAAC,oBAAoB,CAAC,KAAK,CAAC,CAAC;QACtC,CAAC,CAAC,CAAC,CAAC;QACJ,YAAY,CAAC,GAAG,CAAC,KAAK,CAAC,UAAU,CAAC,UAAU,CAAC,CAAC,CAAC;QAC/C,OAAO,YAAY,CAAC;IACtB,CAAC;IAED,KAAK;QACH,MAAM,OAAO,GAAG,IAAI,CAAC;QACrB,MAAM,cAAc,GAAG,OAAO,CAAC,QAAQ,CAAC,MAAM,CAAC;QAE/C,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,cAAc,EAAE,CAAC,EAAE,EAAE;YACvC,CAAC,GAAG,EAAE;gBACJ,IAAI,OAAO,GAAG,OAAO,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC;gBAElC,OAAO,CAAC,SAAS,CAAC,QAAQ,CACxB,GAAG,EAAE,GAAG,OAAO,CAAC,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,EAChD,OAAO,CAAC,KAAK,CACd,CAAC;YACJ,CAAC,CAAC,EAAE,CAAC;SACN;IACH,CAAC;CACF;AACD,WAAW,CAAC,aAAa,EAAE,CAAC,oBAAoB,CAAC,CAAC,CAAC"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLog.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLog.js new file mode 100644 index 00000000..c421751b --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLog.js @@ -0,0 +1,7 @@ +export class SubscriptionLog { +    constructor(subscribedFrame, unsubscribedFrame = Number.POSITIVE_INFINITY) { +        this.subscribedFrame = subscribedFrame; +        this.unsubscribedFrame = unsubscribedFrame; +    } +} +//# sourceMappingURL=SubscriptionLog.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLog.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLog.js.map new file mode 100644 index 00000000..8903b165 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLog.js.map @@ -0,0 +1 @@ +{"version":3,"file":"SubscriptionLog.js","sources":["../../../src/internal/testing/SubscriptionLog.ts"],"names":[],"mappings":"AAAA,MAAM,OAAO,eAAe;IAC1B,YAAmB,eAAuB,EACvB,oBAA4B,MAAM,CAAC,iBAAiB;QADpD,oBAAe,GAAf,eAAe,CAAQ;QACvB,sBAAiB,GAAjB,iBAAiB,CAAmC;IACvE,CAAC;CACF"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLoggable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLoggable.js new file mode 100644 index 00000000..08a00d72 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLoggable.js @@ -0,0 +1,16 @@ +import { SubscriptionLog } from './SubscriptionLog'; +export class SubscriptionLoggable { +    constructor() { +        this.subscriptions = []; +    } +    logSubscribedFrame() { +        this.subscriptions.push(new SubscriptionLog(this.scheduler.now())); +        return this.subscriptions.length - 1; +    } +    logUnsubscribedFrame(index) { +        const subscriptionLogs = this.subscriptions; +        const oldSubscriptionLog = subscriptionLogs[index]; +        subscriptionLogs[index] = new SubscriptionLog(oldSubscriptionLog.subscribedFrame, this.scheduler.now()); +    } +} +//# sourceMappingURL=SubscriptionLoggable.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLoggable.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLoggable.js.map new file mode 100644 index 00000000..37f16beb --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/SubscriptionLoggable.js.map @@ -0,0 +1 @@ +{"version":3,"file":"SubscriptionLoggable.js","sources":["../../../src/internal/testing/SubscriptionLoggable.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,eAAe,EAAE,MAAM,mBAAmB,CAAC;AAEpD,MAAM,OAAO,oBAAoB;IAAjC;QACS,kBAAa,GAAsB,EAAE,CAAC;IAgB/C,CAAC;IAbC,kBAAkB;QAChB,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,IAAI,eAAe,CAAC,IAAI,CAAC,SAAS,CAAC,GAAG,EAAE,CAAC,CAAC,CAAC;QACnE,OAAO,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,CAAC,CAAC;IACvC,CAAC;IAED,oBAAoB,CAAC,KAAa;QAChC,MAAM,gBAAgB,GAAG,IAAI,CAAC,aAAa,CAAC;QAC5C,MAAM,kBAAkB,GAAG,gBAAgB,CAAC,KAAK,CAAC,CAAC;QACnD,gBAAgB,CAAC,KAAK,CAAC,GAAG,IAAI,eAAe,CAC3C,kBAAkB,CAAC,eAAe,EAClC,IAAI,CAAC,SAAS,CAAC,GAAG,EAAE,CACrB,CAAC;IACJ,CAAC;CACF"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestMessage.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestMessage.js new file mode 100644 index 00000000..908175c7 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestMessage.js @@ -0,0 +1 @@ +//# sourceMappingURL=TestMessage.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestMessage.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestMessage.js.map new file mode 100644 index 00000000..b19facd5 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestMessage.js.map @@ -0,0 +1 @@ +{"version":3,"file":"TestMessage.js","sources":["../../../src/internal/testing/TestMessage.ts"],"names":[],"mappings":""} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestScheduler.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestScheduler.js new file mode 100644 index 00000000..3b8a55fa --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestScheduler.js @@ -0,0 +1,322 @@ +import { Observable } from '../Observable'; +import { Notification } from '../Notification'; +import { ColdObservable } from './ColdObservable'; +import { HotObservable } from './HotObservable'; +import { SubscriptionLog } from './SubscriptionLog'; +import { VirtualTimeScheduler, VirtualAction } from '../scheduler/VirtualTimeScheduler'; +import { AsyncScheduler } from '../scheduler/AsyncScheduler'; +const defaultMaxFrame = 750; +export class TestScheduler extends VirtualTimeScheduler { +    constructor(assertDeepEqual) { +        super(VirtualAction, defaultMaxFrame); +        this.assertDeepEqual = assertDeepEqual; +        this.hotObservables = []; +        this.coldObservables = []; +        this.flushTests = []; +        this.runMode = false; +    } +    createTime(marbles) { +        const indexOf = marbles.indexOf('|'); +        if (indexOf === -1) { +            throw new Error('marble diagram for time should have a completion marker "|"'); +        } +        return indexOf * TestScheduler.frameTimeFactor; +    } +    createColdObservable(marbles, values, error) { +        if (marbles.indexOf('^') !== -1) { +            throw new Error('cold observable cannot have subscription offset "^"'); +        } +        if (marbles.indexOf('!') !== -1) { +            throw new Error('cold observable cannot have unsubscription marker "!"'); +        } +        const messages = TestScheduler.parseMarbles(marbles, values, error, undefined, this.runMode); +        const cold = new ColdObservable(messages, this); +        this.coldObservables.push(cold); +        return cold; +    } +    createHotObservable(marbles, values, error) { +        if (marbles.indexOf('!') !== -1) { +            throw new Error('hot observable cannot have unsubscription marker "!"'); +        } +        const messages = TestScheduler.parseMarbles(marbles, values, error, undefined, this.runMode); +        const subject = new HotObservable(messages, this); +        this.hotObservables.push(subject); +        return subject; +    } +    materializeInnerObservable(observable, outerFrame) { +        const messages = []; +        observable.subscribe((value) => { +            messages.push({ frame: this.frame - outerFrame, notification: Notification.createNext(value) }); +        }, (err) => { +            messages.push({ frame: this.frame - outerFrame, notification: Notification.createError(err) }); +        }, () => { +            messages.push({ frame: this.frame - outerFrame, notification: Notification.createComplete() }); +        }); +        return messages; +    } +    expectObservable(observable, subscriptionMarbles = null) { +        const actual = []; +        const flushTest = { actual, ready: false }; +        const subscriptionParsed = TestScheduler.parseMarblesAsSubscriptions(subscriptionMarbles, this.runMode); +        const subscriptionFrame = subscriptionParsed.subscribedFrame === Number.POSITIVE_INFINITY ? +            0 : subscriptionParsed.subscribedFrame; +        const unsubscriptionFrame = subscriptionParsed.unsubscribedFrame; +        let subscription; +        this.schedule(() => { +            subscription = observable.subscribe(x => { +                let value = x; +                if (x instanceof Observable) { +                    value = this.materializeInnerObservable(value, this.frame); +                } +                actual.push({ frame: this.frame, notification: Notification.createNext(value) }); +            }, (err) => { +                actual.push({ frame: this.frame, notification: Notification.createError(err) }); +            }, () => { +                actual.push({ frame: this.frame, notification: Notification.createComplete() }); +            }); +        }, subscriptionFrame); +        if (unsubscriptionFrame !== Number.POSITIVE_INFINITY) { +            this.schedule(() => subscription.unsubscribe(), unsubscriptionFrame); +        } +        this.flushTests.push(flushTest); +        const { runMode } = this; +        return { +            toBe(marbles, values, errorValue) { +                flushTest.ready = true; +                flushTest.expected = TestScheduler.parseMarbles(marbles, values, errorValue, true, runMode); +            } +        }; +    } +    expectSubscriptions(actualSubscriptionLogs) { +        const flushTest = { actual: actualSubscriptionLogs, ready: false }; +        this.flushTests.push(flushTest); +        const { runMode } = this; +        return { +            toBe(marbles) { +                const marblesArray = (typeof marbles === 'string') ? [marbles] : marbles; +                flushTest.ready = true; +                flushTest.expected = marblesArray.map(marbles => TestScheduler.parseMarblesAsSubscriptions(marbles, runMode)); +            } +        }; +    } +    flush() { +        const hotObservables = this.hotObservables; +        while (hotObservables.length > 0) { +            hotObservables.shift().setup(); +        } +        super.flush(); +        this.flushTests = this.flushTests.filter(test => { +            if (test.ready) { +                this.assertDeepEqual(test.actual, test.expected); +                return false; +            } +            return true; +        }); +    } +    static parseMarblesAsSubscriptions(marbles, runMode = false) { +        if (typeof marbles !== 'string') { +            return new SubscriptionLog(Number.POSITIVE_INFINITY); +        } +        const len = marbles.length; +        let groupStart = -1; +        let subscriptionFrame = Number.POSITIVE_INFINITY; +        let unsubscriptionFrame = Number.POSITIVE_INFINITY; +        let frame = 0; +        for (let i = 0; i < len; i++) { +            let nextFrame = frame; +            const advanceFrameBy = (count) => { +                nextFrame += count * this.frameTimeFactor; +            }; +            const c = marbles[i]; +            switch (c) { +                case ' ': +                    if (!runMode) { +                        advanceFrameBy(1); +                    } +                    break; +                case '-': +                    advanceFrameBy(1); +                    break; +                case '(': +                    groupStart = frame; +                    advanceFrameBy(1); +                    break; +                case ')': +                    groupStart = -1; +                    advanceFrameBy(1); +                    break; +                case '^': +                    if (subscriptionFrame !== Number.POSITIVE_INFINITY) { +                        throw new Error('found a second subscription point \'^\' in a ' + +                            'subscription marble diagram. There can only be one.'); +                    } +                    subscriptionFrame = groupStart > -1 ? groupStart : frame; +                    advanceFrameBy(1); +                    break; +                case '!': +                    if (unsubscriptionFrame !== Number.POSITIVE_INFINITY) { +                        throw new Error('found a second subscription point \'^\' in a ' + +                            'subscription marble diagram. There can only be one.'); +                    } +                    unsubscriptionFrame = groupStart > -1 ? groupStart : frame; +                    break; +                default: +                    if (runMode && c.match(/^[0-9]$/)) { +                        if (i === 0 || marbles[i - 1] === ' ') { +                            const buffer = marbles.slice(i); +                            const match = buffer.match(/^([0-9]+(?:\.[0-9]+)?)(ms|s|m) /); +                            if (match) { +                                i += match[0].length - 1; +                                const duration = parseFloat(match[1]); +                                const unit = match[2]; +                                let durationInMs; +                                switch (unit) { +                                    case 'ms': +                                        durationInMs = duration; +                                        break; +                                    case 's': +                                        durationInMs = duration * 1000; +                                        break; +                                    case 'm': +                                        durationInMs = duration * 1000 * 60; +                                        break; +                                    default: +                                        break; +                                } +                                advanceFrameBy(durationInMs / this.frameTimeFactor); +                                break; +                            } +                        } +                    } +                    throw new Error('there can only be \'^\' and \'!\' markers in a ' + +                        'subscription marble diagram. Found instead \'' + c + '\'.'); +            } +            frame = nextFrame; +        } +        if (unsubscriptionFrame < 0) { +            return new SubscriptionLog(subscriptionFrame); +        } +        else { +            return new SubscriptionLog(subscriptionFrame, unsubscriptionFrame); +        } +    } +    static parseMarbles(marbles, values, errorValue, materializeInnerObservables = false, runMode = false) { +        if (marbles.indexOf('!') !== -1) { +            throw new Error('conventional marble diagrams cannot have the ' + +                'unsubscription marker "!"'); +        } +        const len = marbles.length; +        const testMessages = []; +        const subIndex = runMode ? marbles.replace(/^[ ]+/, '').indexOf('^') : marbles.indexOf('^'); +        let frame = subIndex === -1 ? 0 : (subIndex * -this.frameTimeFactor); +        const getValue = typeof values !== 'object' ? +            (x) => x : +            (x) => { +                if (materializeInnerObservables && values[x] instanceof ColdObservable) { +                    return values[x].messages; +                } +                return values[x]; +            }; +        let groupStart = -1; +        for (let i = 0; i < len; i++) { +            let nextFrame = frame; +            const advanceFrameBy = (count) => { +                nextFrame += count * this.frameTimeFactor; +            }; +            let notification; +            const c = marbles[i]; +            switch (c) { +                case ' ': +                    if (!runMode) { +                        advanceFrameBy(1); +                    } +                    break; +                case '-': +                    advanceFrameBy(1); +                    break; +                case '(': +                    groupStart = frame; +                    advanceFrameBy(1); +                    break; +                case ')': +                    groupStart = -1; +                    advanceFrameBy(1); +                    break; +                case '|': +                    notification = Notification.createComplete(); +                    advanceFrameBy(1); +                    break; +                case '^': +                    advanceFrameBy(1); +                    break; +                case '#': +                    notification = Notification.createError(errorValue || 'error'); +                    advanceFrameBy(1); +                    break; +                default: +                    if (runMode && c.match(/^[0-9]$/)) { +                        if (i === 0 || marbles[i - 1] === ' ') { +                            const buffer = marbles.slice(i); +                            const match = buffer.match(/^([0-9]+(?:\.[0-9]+)?)(ms|s|m) /); +                            if (match) { +                                i += match[0].length - 1; +                                const duration = parseFloat(match[1]); +                                const unit = match[2]; +                                let durationInMs; +                                switch (unit) { +                                    case 'ms': +                                        durationInMs = duration; +                                        break; +                                    case 's': +                                        durationInMs = duration * 1000; +                                        break; +                                    case 'm': +                                        durationInMs = duration * 1000 * 60; +                                        break; +                                    default: +                                        break; +                                } +                                advanceFrameBy(durationInMs / this.frameTimeFactor); +                                break; +                            } +                        } +                    } +                    notification = Notification.createNext(getValue(c)); +                    advanceFrameBy(1); +                    break; +            } +            if (notification) { +                testMessages.push({ frame: groupStart > -1 ? groupStart : frame, notification }); +            } +            frame = nextFrame; +        } +        return testMessages; +    } +    run(callback) { +        const prevFrameTimeFactor = TestScheduler.frameTimeFactor; +        const prevMaxFrames = this.maxFrames; +        TestScheduler.frameTimeFactor = 1; +        this.maxFrames = Number.POSITIVE_INFINITY; +        this.runMode = true; +        AsyncScheduler.delegate = this; +        const helpers = { +            cold: this.createColdObservable.bind(this), +            hot: this.createHotObservable.bind(this), +            flush: this.flush.bind(this), +            expectObservable: this.expectObservable.bind(this), +            expectSubscriptions: this.expectSubscriptions.bind(this), +        }; +        try { +            const ret = callback(helpers); +            this.flush(); +            return ret; +        } +        finally { +            TestScheduler.frameTimeFactor = prevFrameTimeFactor; +            this.maxFrames = prevMaxFrames; +            this.runMode = false; +            AsyncScheduler.delegate = undefined; +        } +    } +} +//# sourceMappingURL=TestScheduler.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestScheduler.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestScheduler.js.map new file mode 100644 index 00000000..b2c5bdc4 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/testing/TestScheduler.js.map @@ -0,0 +1 @@ +{"version":3,"file":"TestScheduler.js","sources":["../../../src/internal/testing/TestScheduler.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAC3C,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAC/C,OAAO,EAAE,cAAc,EAAE,MAAM,kBAAkB,CAAC;AAClD,OAAO,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAC;AAEhD,OAAO,EAAE,eAAe,EAAE,MAAM,mBAAmB,CAAC;AAEpD,OAAO,EAAE,oBAAoB,EAAE,aAAa,EAAE,MAAM,mCAAmC,CAAC;AACxF,OAAO,EAAE,cAAc,EAAE,MAAM,6BAA6B,CAAC;AAE7D,MAAM,eAAe,GAAW,GAAG,CAAC;AAmBpC,MAAM,OAAO,aAAc,SAAQ,oBAAoB;IAMrD,YAAmB,eAA+D;QAChF,KAAK,CAAC,aAAa,EAAE,eAAe,CAAC,CAAC;QADrB,oBAAe,GAAf,eAAe,CAAgD;QALlE,mBAAc,GAAyB,EAAE,CAAC;QAC1C,oBAAe,GAA0B,EAAE,CAAC;QACpD,eAAU,GAAoB,EAAE,CAAC;QACjC,YAAO,GAAG,KAAK,CAAC;IAIxB,CAAC;IAED,UAAU,CAAC,OAAe;QACxB,MAAM,OAAO,GAAW,OAAO,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;QAC7C,IAAI,OAAO,KAAK,CAAC,CAAC,EAAE;YAClB,MAAM,IAAI,KAAK,CAAC,6DAA6D,CAAC,CAAC;SAChF;QACD,OAAO,OAAO,GAAG,aAAa,CAAC,eAAe,CAAC;IACjD,CAAC;IAOD,oBAAoB,CAAa,OAAe,EAAE,MAAgC,EAAE,KAAW;QAC7F,IAAI,OAAO,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,EAAE;YAC/B,MAAM,IAAI,KAAK,CAAC,qDAAqD,CAAC,CAAC;SACxE;QACD,IAAI,OAAO,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,EAAE;YAC/B,MAAM,IAAI,KAAK,CAAC,uDAAuD,CAAC,CAAC;SAC1E;QACD,MAAM,QAAQ,GAAG,aAAa,CAAC,YAAY,CAAC,OAAO,EAAE,MAAM,EAAE,KAAK,EAAE,SAAS,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;QAC7F,MAAM,IAAI,GAAG,IAAI,cAAc,CAAI,QAAQ,EAAE,IAAI,CAAC,CAAC;QACnD,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAChC,OAAO,IAAI,CAAC;IACd,CAAC;IAOD,mBAAmB,CAAa,OAAe,EAAE,MAAgC,EAAE,KAAW;QAC5F,IAAI,OAAO,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,EAAE;YAC/B,MAAM,IAAI,KAAK,CAAC,sDAAsD,CAAC,CAAC;SACzE;QACD,MAAM,QAAQ,GAAG,aAAa,CAAC,YAAY,CAAC,OAAO,EAAE,MAAM,EAAE,KAAK,EAAE,SAAS,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;QAC7F,MAAM,OAAO,GAAG,IAAI,aAAa,CAAI,QAAQ,EAAE,IAAI,CAAC,CAAC;QACrD,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QAClC,OAAO,OAAO,CAAC;IACjB,CAAC;IAEO,0BAA0B,CAAC,UAA2B,EAC3B,UAAkB;QACnD,MAAM,QAAQ,GAAkB,EAAE,CAAC;QACnC,UAAU,CAAC,SAAS,CAAC,CAAC,KAAK,EAAE,EAAE;YAC7B,QAAQ,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,GAAG,UAAU,EAAE,YAAY,EAAE,YAAY,CAAC,UAAU,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;QAClG,CAAC,EAAE,CAAC,GAAG,EAAE,EAAE;YACT,QAAQ,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,GAAG,UAAU,EAAE,YAAY,EAAE,YAAY,CAAC,WAAW,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;QACjG,CAAC,EAAE,GAAG,EAAE;YACN,QAAQ,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,GAAG,UAAU,EAAE,YAAY,EAAE,YAAY,CAAC,cAAc,EAAE,EAAE,CAAC,CAAC;QACjG,CAAC,CAAC,CAAC;QACH,OAAO,QAAQ,CAAC;IAClB,CAAC;IAED,gBAAgB,CAAC,UAA2B,EAC3B,sBAA8B,IAAI;QACjD,MAAM,MAAM,GAAkB,EAAE,CAAC;QACjC,MAAM,SAAS,GAAkB,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC;QAC1D,MAAM,kBAAkB,GAAG,aAAa,CAAC,2BAA2B,CAAC,mBAAmB,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;QACxG,MAAM,iBAAiB,GAAG,kBAAkB,CAAC,eAAe,KAAK,MAAM,CAAC,iBAAiB,CAAC,CAAC;YACzF,CAAC,CAAC,CAAC,CAAC,kBAAkB,CAAC,eAAe,CAAC;QACzC,MAAM,mBAAmB,GAAG,kBAAkB,CAAC,iBAAiB,CAAC;QACjE,IAAI,YAA0B,CAAC;QAE/B,IAAI,CAAC,QAAQ,CAAC,GAAG,EAAE;YACjB,YAAY,GAAG,UAAU,CAAC,SAAS,CAAC,CAAC,CAAC,EAAE;gBACtC,IAAI,KAAK,GAAG,CAAC,CAAC;gBAEd,IAAI,CAAC,YAAY,UAAU,EAAE;oBAC3B,KAAK,GAAG,IAAI,CAAC,0BAA0B,CAAC,KAAK,EAAE,IAAI,CAAC,KAAK,CAAC,CAAC;iBAC5D;gBACD,MAAM,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,EAAE,YAAY,EAAE,YAAY,CAAC,UAAU,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YACnF,CAAC,EAAE,CAAC,GAAG,EAAE,EAAE;gBACT,MAAM,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,EAAE,YAAY,EAAE,YAAY,CAAC,WAAW,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YAClF,CAAC,EAAE,GAAG,EAAE;gBACN,MAAM,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,IAAI,CAAC,KAAK,EAAE,YAAY,EAAE,YAAY,CAAC,cAAc,EAAE,EAAE,CAAC,CAAC;YAClF,CAAC,CAAC,CAAC;QACL,CAAC,EAAE,iBAAiB,CAAC,CAAC;QAEtB,IAAI,mBAAmB,KAAK,MAAM,CAAC,iBAAiB,EAAE;YACpD,IAAI,CAAC,QAAQ,CAAC,GAAG,EAAE,CAAC,YAAY,CAAC,WAAW,EAAE,EAAE,mBAAmB,CAAC,CAAC;SACtE;QAED,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;QAChC,MAAM,EAAE,OAAO,EAAE,GAAG,IAAI,CAAC;QAEzB,OAAO;YACL,IAAI,CAAC,OAAe,EAAE,MAAY,EAAE,UAAgB;gBAClD,SAAS,CAAC,KAAK,GAAG,IAAI,CAAC;gBACvB,SAAS,CAAC,QAAQ,GAAG,aAAa,CAAC,YAAY,CAAC,OAAO,EAAE,MAAM,EAAE,UAAU,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;YAC9F,CAAC;SACF,CAAC;IACJ,CAAC;IAED,mBAAmB,CAAC,sBAAyC;QAC3D,MAAM,SAAS,GAAkB,EAAE,MAAM,EAAE,sBAAsB,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC;QAClF,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;QAChC,MAAM,EAAE,OAAO,EAAE,GAAG,IAAI,CAAC;QACzB,OAAO;YACL,IAAI,CAAC,OAA0B;gBAC7B,MAAM,YAAY,GAAa,CAAC,OAAO,OAAO,KAAK,QAAQ,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC;gBACnF,SAAS,CAAC,KAAK,GAAG,IAAI,CAAC;gBACvB,SAAS,CAAC,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,OAAO,CAAC,EAAE,CAC9C,aAAa,CAAC,2BAA2B,CAAC,OAAO,EAAE,OAAO,CAAC,CAC5D,CAAC;YACJ,CAAC;SACF,CAAC;IACJ,CAAC;IAED,KAAK;QACH,MAAM,cAAc,GAAG,IAAI,CAAC,cAAc,CAAC;QAC3C,OAAO,cAAc,CAAC,MAAM,GAAG,CAAC,EAAE;YAChC,cAAc,CAAC,KAAK,EAAE,CAAC,KAAK,EAAE,CAAC;SAChC;QAED,KAAK,CAAC,KAAK,EAAE,CAAC;QAEd,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE;YAC9C,IAAI,IAAI,CAAC,KAAK,EAAE;gBACd,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,QAAQ,CAAC,CAAC;gBACjD,OAAO,KAAK,CAAC;aACd;YACD,OAAO,IAAI,CAAC;QACd,CAAC,CAAC,CAAC;IACL,CAAC;IAGD,MAAM,CAAC,2BAA2B,CAAC,OAAe,EAAE,OAAO,GAAG,KAAK;QACjE,IAAI,OAAO,OAAO,KAAK,QAAQ,EAAE;YAC/B,OAAO,IAAI,eAAe,CAAC,MAAM,CAAC,iBAAiB,CAAC,CAAC;SACtD;QACD,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC;QAC3B,IAAI,UAAU,GAAG,CAAC,CAAC,CAAC;QACpB,IAAI,iBAAiB,GAAG,MAAM,CAAC,iBAAiB,CAAC;QACjD,IAAI,mBAAmB,GAAG,MAAM,CAAC,iBAAiB,CAAC;QACnD,IAAI,KAAK,GAAG,CAAC,CAAC;QAEd,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,GAAG,EAAE,CAAC,EAAE,EAAE;YAC5B,IAAI,SAAS,GAAG,KAAK,CAAC;YACtB,MAAM,cAAc,GAAG,CAAC,KAAa,EAAE,EAAE;gBACvC,SAAS,IAAI,KAAK,GAAG,IAAI,CAAC,eAAe,CAAC;YAC5C,CAAC,CAAC;YACF,MAAM,CAAC,GAAG,OAAO,CAAC,CAAC,CAAC,CAAC;YACrB,QAAQ,CAAC,EAAE;gBACT,KAAK,GAAG;oBAEN,IAAI,CAAC,OAAO,EAAE;wBACZ,cAAc,CAAC,CAAC,CAAC,CAAC;qBACnB;oBACD,MAAM;gBACR,KAAK,GAAG;oBACN,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,UAAU,GAAG,KAAK,CAAC;oBACnB,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,UAAU,GAAG,CAAC,CAAC,CAAC;oBAChB,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,IAAI,iBAAiB,KAAK,MAAM,CAAC,iBAAiB,EAAE;wBAClD,MAAM,IAAI,KAAK,CAAC,+CAA+C;4BAC7D,qDAAqD,CAAC,CAAC;qBAC1D;oBACD,iBAAiB,GAAG,UAAU,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC;oBACzD,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,IAAI,mBAAmB,KAAK,MAAM,CAAC,iBAAiB,EAAE;wBACpD,MAAM,IAAI,KAAK,CAAC,+CAA+C;4BAC7D,qDAAqD,CAAC,CAAC;qBAC1D;oBACD,mBAAmB,GAAG,UAAU,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC;oBAC3D,MAAM;gBACR;oBAEE,IAAI,OAAO,IAAI,CAAC,CAAC,KAAK,CAAC,SAAS,CAAC,EAAE;wBAGjC,IAAI,CAAC,KAAK,CAAC,IAAI,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,KAAK,GAAG,EAAE;4BACrC,MAAM,MAAM,GAAG,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;4BAChC,MAAM,KAAK,GAAG,MAAM,CAAC,KAAK,CAAC,iCAAiC,CAAC,CAAC;4BAC9D,IAAI,KAAK,EAAE;gCACT,CAAC,IAAI,KAAK,CAAC,CAAC,CAAC,CAAC,MAAM,GAAG,CAAC,CAAC;gCACzB,MAAM,QAAQ,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC;gCACtC,MAAM,IAAI,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;gCACtB,IAAI,YAAoB,CAAC;gCAEzB,QAAQ,IAAI,EAAE;oCACZ,KAAK,IAAI;wCACP,YAAY,GAAG,QAAQ,CAAC;wCACxB,MAAM;oCACR,KAAK,GAAG;wCACN,YAAY,GAAG,QAAQ,GAAG,IAAI,CAAC;wCAC/B,MAAM;oCACR,KAAK,GAAG;wCACN,YAAY,GAAG,QAAQ,GAAG,IAAI,GAAG,EAAE,CAAC;wCACpC,MAAM;oCACR;wCACE,MAAM;iCACT;gCAED,cAAc,CAAC,YAAY,GAAG,IAAI,CAAC,eAAe,CAAC,CAAC;gCACpD,MAAM;6BACP;yBACF;qBACF;oBAED,MAAM,IAAI,KAAK,CAAC,iDAAiD;wBAC/D,+CAA+C,GAAG,CAAC,GAAG,KAAK,CAAC,CAAC;aAClE;YAED,KAAK,GAAG,SAAS,CAAC;SACnB;QAED,IAAI,mBAAmB,GAAG,CAAC,EAAE;YAC3B,OAAO,IAAI,eAAe,CAAC,iBAAiB,CAAC,CAAC;SAC/C;aAAM;YACL,OAAO,IAAI,eAAe,CAAC,iBAAiB,EAAE,mBAAmB,CAAC,CAAC;SACpE;IACH,CAAC;IAGD,MAAM,CAAC,YAAY,CAAC,OAAe,EACf,MAAY,EACZ,UAAgB,EAChB,8BAAuC,KAAK,EAC5C,OAAO,GAAG,KAAK;QACjC,IAAI,OAAO,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,EAAE;YAC/B,MAAM,IAAI,KAAK,CAAC,+CAA+C;gBAC7D,2BAA2B,CAAC,CAAC;SAChC;QACD,MAAM,GAAG,GAAG,OAAO,CAAC,MAAM,CAAC;QAC3B,MAAM,YAAY,GAAkB,EAAE,CAAC;QACvC,MAAM,QAAQ,GAAG,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,OAAO,EAAE,EAAE,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;QAC5F,IAAI,KAAK,GAAG,QAAQ,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,QAAQ,GAAG,CAAC,IAAI,CAAC,eAAe,CAAC,CAAC;QACrE,MAAM,QAAQ,GAAG,OAAO,MAAM,KAAK,QAAQ,CAAC,CAAC;YAC3C,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,CAAC,CAAC;YACf,CAAC,CAAM,EAAE,EAAE;gBAET,IAAI,2BAA2B,IAAI,MAAM,CAAC,CAAC,CAAC,YAAY,cAAc,EAAE;oBACtE,OAAO,MAAM,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC;iBAC3B;gBACD,OAAO,MAAM,CAAC,CAAC,CAAC,CAAC;YACnB,CAAC,CAAC;QACJ,IAAI,UAAU,GAAG,CAAC,CAAC,CAAC;QAEpB,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,GAAG,EAAE,CAAC,EAAE,EAAE;YAC5B,IAAI,SAAS,GAAG,KAAK,CAAC;YACtB,MAAM,cAAc,GAAG,CAAC,KAAa,EAAE,EAAE;gBACvC,SAAS,IAAI,KAAK,GAAG,IAAI,CAAC,eAAe,CAAC;YAC5C,CAAC,CAAC;YAEF,IAAI,YAA+B,CAAC;YACpC,MAAM,CAAC,GAAG,OAAO,CAAC,CAAC,CAAC,CAAC;YACrB,QAAQ,CAAC,EAAE;gBACT,KAAK,GAAG;oBAEN,IAAI,CAAC,OAAO,EAAE;wBACZ,cAAc,CAAC,CAAC,CAAC,CAAC;qBACnB;oBACD,MAAM;gBACR,KAAK,GAAG;oBACN,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,UAAU,GAAG,KAAK,CAAC;oBACnB,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,UAAU,GAAG,CAAC,CAAC,CAAC;oBAChB,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,YAAY,GAAG,YAAY,CAAC,cAAc,EAAE,CAAC;oBAC7C,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR,KAAK,GAAG;oBACN,YAAY,GAAG,YAAY,CAAC,WAAW,CAAC,UAAU,IAAI,OAAO,CAAC,CAAC;oBAC/D,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;gBACR;oBAEE,IAAI,OAAO,IAAI,CAAC,CAAC,KAAK,CAAC,SAAS,CAAC,EAAE;wBAGjC,IAAI,CAAC,KAAK,CAAC,IAAI,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,KAAK,GAAG,EAAE;4BACrC,MAAM,MAAM,GAAG,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;4BAChC,MAAM,KAAK,GAAG,MAAM,CAAC,KAAK,CAAC,iCAAiC,CAAC,CAAC;4BAC9D,IAAI,KAAK,EAAE;gCACT,CAAC,IAAI,KAAK,CAAC,CAAC,CAAC,CAAC,MAAM,GAAG,CAAC,CAAC;gCACzB,MAAM,QAAQ,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC;gCACtC,MAAM,IAAI,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;gCACtB,IAAI,YAAoB,CAAC;gCAEzB,QAAQ,IAAI,EAAE;oCACZ,KAAK,IAAI;wCACP,YAAY,GAAG,QAAQ,CAAC;wCACxB,MAAM;oCACR,KAAK,GAAG;wCACN,YAAY,GAAG,QAAQ,GAAG,IAAI,CAAC;wCAC/B,MAAM;oCACR,KAAK,GAAG;wCACN,YAAY,GAAG,QAAQ,GAAG,IAAI,GAAG,EAAE,CAAC;wCACpC,MAAM;oCACR;wCACE,MAAM;iCACT;gCAED,cAAc,CAAC,YAAY,GAAG,IAAI,CAAC,eAAe,CAAC,CAAC;gCACpD,MAAM;6BACP;yBACF;qBACF;oBAED,YAAY,GAAG,YAAY,CAAC,UAAU,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,CAAC;oBACpD,cAAc,CAAC,CAAC,CAAC,CAAC;oBAClB,MAAM;aACT;YAED,IAAI,YAAY,EAAE;gBAChB,YAAY,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,UAAU,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,UAAU,CAAC,CAAC,CAAC,KAAK,EAAE,YAAY,EAAE,CAAC,CAAC;aAClF;YAED,KAAK,GAAG,SAAS,CAAC;SACnB;QACD,OAAO,YAAY,CAAC;IACtB,CAAC;IAED,GAAG,CAAI,QAAoC;QACzC,MAAM,mBAAmB,GAAG,aAAa,CAAC,eAAe,CAAC;QAC1D,MAAM,aAAa,GAAG,IAAI,CAAC,SAAS,CAAC;QAErC,aAAa,CAAC,eAAe,GAAG,CAAC,CAAC;QAClC,IAAI,CAAC,SAAS,GAAG,MAAM,CAAC,iBAAiB,CAAC;QAC1C,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC;QACpB,cAAc,CAAC,QAAQ,GAAG,IAAI,CAAC;QAE/B,MAAM,OAAO,GAAG;YACd,IAAI,EAAE,IAAI,CAAC,oBAAoB,CAAC,IAAI,CAAC,IAAI,CAAC;YAC1C,GAAG,EAAE,IAAI,CAAC,mBAAmB,CAAC,IAAI,CAAC,IAAI,CAAC;YACxC,KAAK,EAAE,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC;YAC5B,gBAAgB,EAAE,IAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,IAAI,CAAC;YAClD,mBAAmB,EAAE,IAAI,CAAC,mBAAmB,CAAC,IAAI,CAAC,IAAI,CAAC;SACzD,CAAC;QACF,IAAI;YACF,MAAM,GAAG,GAAG,QAAQ,CAAC,OAAO,CAAC,CAAC;YAC9B,IAAI,CAAC,KAAK,EAAE,CAAC;YACb,OAAO,GAAG,CAAC;SACZ;gBAAS;YACR,aAAa,CAAC,eAAe,GAAG,mBAAmB,CAAC;YACpD,IAAI,CAAC,SAAS,GAAG,aAAa,CAAC;YAC/B,IAAI,CAAC,OAAO,GAAG,KAAK,CAAC;YACrB,cAAc,CAAC,QAAQ,GAAG,SAAS,CAAC;SACrC;IACH,CAAC;CACF"} | 
