create-merged-request

create-merged-request

Merge scattered requests into one, distribute corresponding result to requestor.

Install

npm i create-merged-request rxjs # Please note that rxjs is peer dependency of it

Usage

import { createMergedRequest } from 'create-merged-request'

// `string` is user id
// `User[]` is the response data type that `createRequest` resolves
// `User` is the data type that `createResponse` returns
const mergedRequest = createMergedRequest<string, User[], User>({
  thresholdMs: 0, // time threshold to merged request into one request
  createRequest(ids) {
    return fetchUsers(ids) // type: (ids: string[]) => Promise<User[]>
  },
  createResponse(id, users) {
    return users.find((user) => user.id === id)! // type: User
  }
})

// Only 1 `fetchUsers` will be called
mergedRequest(userId1).then((user) => console.log(user))
mergedRequest(userId2).then((user) => console.log(user))
mergedRequest(userId3).then((user) => console.log(user))