IStoreSDK: IBaseProtocolSDK & {
    protocol: IBaseProtocolCore;
    queryGenerator: (<T>(decoders, options?) => AsyncGenerator<Promise<T | undefined>[]>);
    queryWithOrderedCallback: (<T>(decoders, callback, options?) => Promise<void>);
    queryWithPromiseCallback: (<T>(decoders, callback, options?) => Promise<void>);
    createCursor(message): Cursor;
}

Type declaration

  • protocol: IBaseProtocolCore
  • queryGenerator: (<T>(decoders, options?) => AsyncGenerator<Promise<T | undefined>[]>)
      • <T>(decoders, options?): AsyncGenerator<Promise<T | undefined>[]>
      • Type Parameters

        Parameters

        Returns AsyncGenerator<Promise<T | undefined>[]>

  • queryWithOrderedCallback: (<T>(decoders, callback, options?) => Promise<void>)
      • <T>(decoders, callback, options?): Promise<void>
      • Type Parameters

        Parameters

        • decoders: IDecoder<T>[]
        • callback: ((message) => Promise<void | boolean> | boolean | void)
            • (message): Promise<void | boolean> | boolean | void
            • Parameters

              • message: T

              Returns Promise<void | boolean> | boolean | void

        • Optional options: StoreQueryOptions

        Returns Promise<void>

  • queryWithPromiseCallback: (<T>(decoders, callback, options?) => Promise<void>)
      • <T>(decoders, callback, options?): Promise<void>
      • Type Parameters

        Parameters

        • decoders: IDecoder<T>[]
        • callback: ((message) => Promise<void | boolean> | boolean | void)
            • (message): Promise<void | boolean> | boolean | void
            • Parameters

              • message: Promise<T | undefined>

              Returns Promise<void | boolean> | boolean | void

        • Optional options: StoreQueryOptions

        Returns Promise<void>

  • createCursor:function

Generated using TypeDoc