{"map":"{\"version\":3,\"file\":\"rewrite.js\",\"sourceRoot\":\"\",\"sources\":[\"../../../src/operators/rewrite.ts\"],\"names\":[],\"mappings\":\"AAAA;;;;;;;;;;;;;;GAcG;;AAEH,OAAO,EACL,KAAK,EACL,YAAY,EACZ,aAAa,GACd,MAAM,eAAe,CAAC;AAavB,OAAO,EACL,SAAS,GACV,MAAM,aAAa,CAAC;AAerB,MAAM,CAAC,MAAM,iBAAiB,GAAG,MAAM,EAAE,CAAC;AAE1C,MAAM,sBAAwG,UAAa;IACzH,MAAM,CAAC,KAAM,SAAQ,UAAU;QAC7B,OAAO,CAAoD,EAAE,OAAO,EAAE,YAAY,GAAG,iBAAiB,EAAE,eAAe,GAAG,IAAI,EAAwB;YACpJ,IAAI,IAA8B,CAAC;YACnC,IAAI,MAAoH,CAAC;YACzH,IAAI,iBAAiB,GAAG,KAAK,CAAC;YAE9B,EAAE,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;gBACnB,IAAI,GAAG,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,CAAC,CAAC;gBAClC,MAAM,GAAG,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,EAAE,CAAC,CAAC;YACxC,CAAC;YAAC,IAAI,CAAC,CAAC;gBACN,IAAI,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;gBAC5B,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;gBAChC,iBAAiB,GAAG,IAAI,CAAC;YAC3B,CAAC;YAED,IAAI,QAAQ,GAAmD,IAAI,CAAC;YAEpE,EAAE,CAAC,CAAC,CAAC,eAAe,CAAC,CAAC,CAAC;gBACrB,MAAM,GAAG,MAAM,CAAC,GAAG,CACjB,KAAK,IAAI,YAAY,CAAC,KAAK,CAAC;sBACxB,KAAK,CAAC,SAAS,EAAE;sBACjB,SAAS,CAAC,KAAK,CAAC,CACI,CAAC;gBAC3B,QAAQ,GAAG,IAAI,CAAC,SAAS,EAAE,CAAC;YAC9B,CAAC;YAED,MAAM,CAAC,QAAQ,CAAC,qBAAqB,CAAC;gBACpC,SAAS,EAAE,CAAC,EAAE,IAAI,EAAE,KAAK,CAAC,EAA0C;wBAA1C,EAAE,QAAQ,EAAE,UAAU,OAAoB,EAAlB,gDAAgB;oBAChE,EAAE,CAAC,CAAC,UAAU,KAAK,SAAS,CAAC,CAAC,CAAC;wBAC7B,IAAI,GAAG,GAAe,aAAa,CAAC,UAAU,CAAC;8BAC3C,UAAU,CAAC,KAAK;8BAChB,UAAU,CAAC;wBAEf,EAAE,CAAC,CAAC,iBAAiB,CAAC,CAAC,CAAC;4BACtB,GAAG,GAAG,GAAG,CAAC,QAAQ,EAAE,CAAC;wBACvB,CAAC;wBAED,mEAAmE;wBACnE,+DAA+D;wBAC/D,qBAAqB;wBACrB,MAAM,KAAK,GAAI,IAAiB,CAAC,OAAO,CAAC,GAAQ,CAAC,CAAC;wBAEnD,EAAE,CAAC,CAAC,KAAK,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC;4BACjB,EAAE,CAAC,CAAC,YAAY,KAAK,iBAAiB,CAAC,CAAC,CAAC;gCACvC,IAAI,CAAC,YAAiB,CAAC,CAAC;4BAC1B,CAAC;wBACH,CAAC;wBAAC,IAAI,CAAC,CAAC;4BACN,MAAM,YAAY,GAAI,aAA0B,CAAC,KAAK,CAAC,CAAC;4BAExD,4DAA4D;4BAC5D,+DAA+D;4BAC/D,+CAA+C;4BAC/C,EAAE,CAAC,CAAC,YAAY,KAAK,SAAS,CAAC,CAAC,CAAC;gCAC/B,MAAM,KAAK,GAAG,aAAa,CAAC,YAAY,CAAC;sCACrC,YAAY,CAAC,KAAK;sCAClB,YAAY,CAAC;gCAEjB,6DAA6D;gCAC7D,6CAA6C;gCAC7C,2DAA2D;gCAC3D,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC,YAAY,CAAC,IAAI,YAAY,CAAC,SAAS,GAAI,UAA6B,CAAC,SAAS,CAAC,CAAC,CAAC;oCACtG,IAAI,CAAC,KAAK,CAAC,CAAC;gCACd,CAAC;4BACH,CAAC;wBACH,CAAC;oBACH,CAAC;gBACH,CAAC;gBACD,MAAM,EAAE,MAAM;gBACd,gBAAgB,EAAE,KAAK;aACxB,CAAC,CAAC;QACL,CAAC;KACF,CAAC;AACJ,CAAC\"}","code":"/** @license\r\n *  Copyright 2016 - present The Material Motion Authors. All Rights Reserved.\r\n *\r\n *  Licensed under the Apache License, Version 2.0 (the \"License\"); you may not\r\n *  use this file except in compliance with the License. You may obtain a copy\r\n *  of the License at\r\n *\r\n *      http://www.apache.org/licenses/LICENSE-2.0\r\n *\r\n *  Unless required by applicable law or agreed to in writing, software\r\n *  distributed under the License is distributed on an \"AS IS\" BASIS, WITHOUT\r\n *  WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the\r\n *  License for the specific language governing permissions and limitations\r\n *  under the License.\r\n */\r\nimport * as tslib_1 from \"tslib\";\r\nimport { isMap, isObservable, isTimestamped, } from '../typeGuards';\r\nimport { timestamp, } from './timestamp';\r\nexport const SUPPRESS_FAILURES = Symbol();\r\nexport function withRewrite(superclass) {\r\n    return class extends superclass {\r\n        rewrite({ mapping, defaultValue = SUPPRESS_FAILURES, emitOnKeyChange = true }) {\r\n            let keys;\r\n            let values;\r\n            let castKeysToStrings = false;\r\n            if (isMap(mapping)) {\r\n                keys = Array.from(mapping.keys());\r\n                values = Array.from(mapping.values());\r\n            }\r\n            else {\r\n                keys = Object.keys(mapping);\r\n                values = Object.values(mapping);\r\n                castKeysToStrings = true;\r\n            }\r\n            let upstream = this;\r\n            if (!emitOnKeyChange) {\r\n                values = values.map(value => isObservable(value)\r\n                    ? value.timestamp()\r\n                    : timestamp(value));\r\n                upstream = this.timestamp();\r\n            }\r\n            return upstream._reactiveNextOperator({\r\n                operation: ({ emit }) => (_a) => {\r\n                    var { upstream: currentKey } = _a, currentValues = tslib_1.__rest(_a, [\"upstream\"]);\r\n                    if (currentKey !== undefined) {\r\n                        let key = isTimestamped(currentKey)\r\n                            ? currentKey.value\r\n                            : currentKey;\r\n                        if (castKeysToStrings) {\r\n                            key = key.toString();\r\n                        }\r\n                        // TypeScript can't do Array<string | T>.indexOf(string | T), so we\r\n                        // force it to pick one.  Doesn't matter, since the result is a\r\n                        // number either way.\r\n                        const index = keys.indexOf(key);\r\n                        if (index === -1) {\r\n                            if (defaultValue !== SUPPRESS_FAILURES) {\r\n                                emit(defaultValue);\r\n                            }\r\n                        }\r\n                        else {\r\n                            const currentValue = currentValues[index];\r\n                            // Wait until both the currentKey and currentValue have been\r\n                            // defined before emitting.  This also presumes that the author\r\n                            // is not intentionally rewriting to undefined.\r\n                            if (currentValue !== undefined) {\r\n                                const value = isTimestamped(currentValue)\r\n                                    ? currentValue.value\r\n                                    : currentValue;\r\n                                // Prevent stale values from being emitted by only forwarding\r\n                                // values that are newer than the key, unless\r\n                                // emitOnKeyChange is set (which will omit the timestamps).\r\n                                if (!isTimestamped(currentValue) || currentValue.timestamp > currentKey.timestamp) {\r\n                                    emit(value);\r\n                                }\r\n                            }\r\n                        }\r\n                    }\r\n                },\r\n                inputs: values,\r\n                waitForAllValues: false\r\n            });\r\n        }\r\n    };\r\n}\r\n//# sourceMappingURL=rewrite.js.map","dts":{"name":"/Users/brentons/Projects/material-motion-js/packages/core/operators/rewrite.d.ts","text":"import { Constructor, Dict, MotionReactiveNextOperable, MotionTimestampable, ObservableWithMotionOperators } from '../types';\r\nexport declare type RewritableOptions<U> = Partial<{\r\n    defaultValue: U | symbol;\r\n    emitOnKeyChange: boolean;\r\n}>;\r\nexport declare type RewriteArgs<T, R, U> = RewritableOptions<U> & {\r\n    mapping: Dict<R> | Map<T, R>;\r\n};\r\nexport interface MotionRewritable<T> {\r\n    rewrite<U, R extends U | ObservableWithMotionOperators<U>>(kwargs: RewriteArgs<T, R, U>): ObservableWithMotionOperators<U>;\r\n}\r\nexport declare const SUPPRESS_FAILURES: symbol;\r\nexport declare function withRewrite<T, S extends Constructor<MotionReactiveNextOperable<T> & MotionTimestampable<T>>>(superclass: S): S & Constructor<MotionRewritable<T>>;\r\n"}}