Pending request for cleanup on clear()

interface PendingRequest {
    handler: (topic: string, payload: Buffer) => void;
    reject: (err: Error) => void;
    timer: Timeout;
    topicsToUnsubscribe: string[];
}

Properties

handler: (topic: string, payload: Buffer) => void
reject: (err: Error) => void
timer: Timeout
topicsToUnsubscribe: string[]

MQTT topics this handler was subscribed to (for unsubscribe)