/** * @module memoryStore */ import type { PacketId } from "./deps.ts"; import type { PacketStore, PendingAckOutgoing, pendingIncoming, PendingOutgoing, PendingOutgoingPackets, Store } from "./store.ts"; /** * In-memory implementation of the Store interface for managing MQTT packet storage */ export declare class MemoryStore implements Store { /** Current packet ID counter */ private packetId; /** Map of pending incoming packets */ pendingIncoming: PacketStore; /** Map of pending outgoing packets */ pendingOutgoing: PacketStore; /** Map of pending acknowledgment outgoing packets */ pendingAckOutgoing: PacketStore; /** * Creates a new MemoryStore instance */ constructor(); /** * Generates the next available packet ID * @returns {PacketId} The next available packet ID * @throws {Error} If no unused packet ID is available */ nextId(): PacketId; /** * Asynchronously yields all pending outgoing packets * @yields {PendingOutgoingPackets} Pending outgoing packets */ pendingOutgoingPackets(): AsyncGenerator; } //# sourceMappingURL=memoryStore.d.ts.map