Function clearAllPendingRequests

  • clearAllPendingRequests(
        pendingRequests: Map<string, PendingRequest>,
        transport: null | MQTTTransport,
        rejectError: Error,
    ): void

    Clears all pending request-response operations. Rejects each with the given error and unsubscribes from response topics.

    Parameters

    • pendingRequests: Map<string, PendingRequest>

      Map of responseTopic → pending request

    • transport: null | MQTTTransport

      MQTT transport for unsubscribe

    • rejectError: Error

      Error to reject pending promises with

    Returns void

Settings

Member Visibility