Interface MessageMapper

interface MessageMapper {
mapInputMessage(inputMessage): IndexEntry | Promise<IndexEntry>;
mapOutputMessages(groupId, entriesIds, payloadsByEntryId): MessagePayload[] | Promise<MessagePayload[]>;
}

Index

Methods

mapInputMessage mapOutputMessages

Methods

mapInputMessage

mapInputMessage(inputMessage): IndexEntry | Promise<IndexEntry>
A mapper to convert your message payload into an IndexEntry.
Parameters
- inputMessage: MessagePayload
Returns IndexEntry | Promise<IndexEntry>
- Defined in types.ts:102

mapOutputMessages

mapOutputMessages(groupId, entriesIds, payloadsByEntryId): MessagePayload[] | Promise<MessagePayload[]>
A mapper to convert a debounced group of entries to the desired output format, supporting just one or multiple messages.
Parameters
- groupId: string
- entriesIds: string[]
- payloadsByEntryId: Record<string, MessagePayload>
Returns MessagePayload[] | Promise<MessagePayload[]>
- Defined in types.ts:109