| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- import {
- IStoreOptions
- } from './store-options'
- /**
- * In-memory implementation of the message store
- * This can actually be saved into files.
- *
- */
- declare class Store {
- /**
- * Store constructor
- *
- * @param {Object} [options] - store options
- */
- constructor (options: IStoreOptions)
- /**
- * Adds a packet to the store, a packet is
- * anything that has a messageId property.
- *
- */
- public put (packet: any, cb?: Function): this
- /**
- * Creates a stream with all the packets in the store
- *
- */
- public createStream (): any
- /**
- * deletes a packet from the store.
- */
- public del (packet: any, cb: Function): this
- /**
- * get a packet from the store.
- */
- public get (packet: any, cb: Function): this
- /**
- * Close the store
- */
- public close (cb: Function): void
- }
- export { Store }
|