Documentation
    Preparing search index...

    Type Alias IStore

    type IStore = {
        multicodec: string;
        queryGenerator: <T extends IDecodedMessage>(
            decoders: IDecoder<T>[],
            options?: Partial<QueryRequestParams>,
        ) => AsyncGenerator<Promise<T | undefined>[]>;
        queryWithOrderedCallback: <T extends IDecodedMessage>(
            decoders: IDecoder<T>[],
            callback: (message: T) => Promise<void | boolean> | boolean | void,
            options?: Partial<QueryRequestParams>,
        ) => Promise<void>;
        queryWithPromiseCallback: <T extends IDecodedMessage>(
            decoders: IDecoder<T>[],
            callback: (
                message: Promise<T | undefined>,
            ) => Promise<void | boolean> | boolean | void,
            options?: Partial<QueryRequestParams>,
        ) => Promise<void>;
        createCursor(message: IDecodedMessage): StoreCursor;
        stop(): void;
    }
    Index

    Properties

    multicodec: string
    queryGenerator: <T extends IDecodedMessage>(
        decoders: IDecoder<T>[],
        options?: Partial<QueryRequestParams>,
    ) => AsyncGenerator<Promise<T | undefined>[]>
    queryWithOrderedCallback: <T extends IDecodedMessage>(
        decoders: IDecoder<T>[],
        callback: (message: T) => Promise<void | boolean> | boolean | void,
        options?: Partial<QueryRequestParams>,
    ) => Promise<void>
    queryWithPromiseCallback: <T extends IDecodedMessage>(
        decoders: IDecoder<T>[],
        callback: (
            message: Promise<T | undefined>,
        ) => Promise<void | boolean> | boolean | void,
        options?: Partial<QueryRequestParams>,
    ) => Promise<void>

    Methods