class RequestQueue
extends EventEmitter
import { RequestQueue } from "https://deno.land/x/kafkasaur@v0.0.7/src/network/requestQueue/index.ts";
Index Signatures
[key: string]: any
Methods
Check and process pending requests either now or in the future
This function will send out as many pending requests as possible taking throttling and in-flight limits into account.
destroy()
fulfillRequest(unnamed 0: any)
maybeThrottle(clientSideThrottleTime: any)
push(pushedRequest: any)
rejectAll(error: any)
Ensure that pending requests will be checked in the future
If there is a client-side throttling in place this will ensure that we will check the pending request queue eventually.
sendSocketRequest(socketRequest: any)