Class RequestQueueSender

Hierarchy

RequestQueueSender

Index

Constructors

constructor

Properties

queue

Methods

Constructors

constructor

new RequestQueueSender(send: function): RequestQueueSender

- Defined in src/lib/send/request-queue.ts:48
Parameters
- send: function
  - - (req: ISerializedRequest): Promise<ISerializedResponse>
    - Parameters
      - req: ISerializedRequest
      Returns Promise<ISerializedResponse>
Returns RequestQueueSender

Properties

Private queue

queue: RequestQueue<ISerializedRequest, ISerializedResponse>

Methods

send

send(req: ISerializedRequest): Promise<ISerializedResponse>

- Defined in src/lib/send/request-queue.ts:53
Parameters
- req: ISerializedRequest
Returns Promise<ISerializedResponse>

sendBatch

sendBatch(reqs: ISerializedRequest[]): Promise<Array<Either<Error, ISerializedResponse>>>

- Defined in src/lib/send/request-queue.ts:69
Parameters
- reqs: ISerializedRequest[]
Returns Promise<Array<Either<Error, ISerializedResponse>>>

sendBatchFp

sendBatchFp(reqs: ISerializedRequest[]): Array<TaskEither<Error, ISerializedResponse>>

- Defined in src/lib/send/request-queue.ts:65
Get array of tasks for sending request-response pairs. Tasks are not squashed into TaskEither<Error, Array<ISerializedResponse>> to ensure the tasks can be easily linked to the corresponding requests.

Parameters
- reqs: ISerializedRequest[]
  
  Requests to send
Returns Array<TaskEither<Error, ISerializedResponse>>

Array of tasks

stop

stop(): Promise<void>

- Defined in src/lib/send/request-queue.ts:74
Returns Promise<void>

Generated using TypeDoc