File Manager

Current Path: Root / node_modules_old/ idb/ build

Parent Directory

Name	Size	Last Modified	Actions
[F]async-iterators.cjs	2.07 KB	2022-10-02 10:07:38
[F]async-iterators.d.ts	11 bytes	2022-10-02 10:07:48
[F]async-iterators.js Edit	2.05 KB	2022-10-02 10:07:43
[F]database-extras.d.ts	11 bytes	2022-10-02 10:07:48
[F]entry.d.ts	31.80 KB	2022-10-02 10:07:49
[F]index.cjs	3.60 KB	2022-10-02 10:07:40
[F]index.d.ts	59 bytes	2022-10-02 10:07:49
[F]index.js Edit	3.44 KB	2022-10-02 10:07:44
[F]umd-with-async-ittr.js Edit	3.95 KB	2022-10-02 10:07:45
[F]umd.js Edit	3.30 KB	2022-10-02 10:07:46
[F]util.d.ts	206 bytes	2022-10-02 10:07:49
[F]wrap-idb-value.cjs	7.41 KB	2022-10-02 10:07:42
[F]wrap-idb-value.d.ts	1.55 KB	2022-10-02 10:07:50
[F]wrap-idb-value.js Edit	7.32 KB	2022-10-02 10:07:46

Editing: async-iterators.js

import { r as replaceTraps, a as reverseTransformCache, u as unwrap, i as instanceOfAny } from './wrap-idb-value.js';

const advanceMethodProps = ['continue', 'continuePrimaryKey', 'advance'];
const methodMap = {};
const advanceResults = new WeakMap();
const ittrProxiedCursorToOriginalProxy = new WeakMap();
const cursorIteratorTraps = {
    get(target, prop) {
        if (!advanceMethodProps.includes(prop))
            return target[prop];
        let cachedFunc = methodMap[prop];
        if (!cachedFunc) {
            cachedFunc = methodMap[prop] = function (...args) {
                advanceResults.set(this, ittrProxiedCursorToOriginalProxy.get(this)[prop](...args));
            };
        }
        return cachedFunc;
    },
};
async function* iterate(...args) {
    // tslint:disable-next-line:no-this-assignment
    let cursor = this;
    if (!(cursor instanceof IDBCursor)) {
        cursor = await cursor.openCursor(...args);
    }
    if (!cursor)
        return;
    cursor = cursor;
    const proxiedCursor = new Proxy(cursor, cursorIteratorTraps);
    ittrProxiedCursorToOriginalProxy.set(proxiedCursor, cursor);
    // Map this double-proxy back to the original, so other cursor methods work.
    reverseTransformCache.set(proxiedCursor, unwrap(cursor));
    while (cursor) {
        yield proxiedCursor;
        // If one of the advancing methods was not called, call continue().
        cursor = await (advanceResults.get(proxiedCursor) || cursor.continue());
        advanceResults.delete(proxiedCursor);
    }
}
function isIteratorProp(target, prop) {
    return ((prop === Symbol.asyncIterator &&
        instanceOfAny(target, [IDBIndex, IDBObjectStore, IDBCursor])) ||
        (prop === 'iterate' && instanceOfAny(target, [IDBIndex, IDBObjectStore])));
}
replaceTraps((oldTraps) => ({
    ...oldTraps,
    get(target, prop, receiver) {
        if (isIteratorProp(target, prop))
            return iterate;
        return oldTraps.get(target, prop, receiver);
    },
    has(target, prop) {
        return isIteratorProp(target, prop) || oldTraps.has(target, prop);
    },
}));

Cancel