Function distinctRelaysBatch
distinctRelaysBatch<T extends MessageWithRelay>( keyFn: (message: T) => string, timeout?: number,): OperatorFunction<T[], T[]> Type Parameters
- T extends MessageWithRelay
Parameters
- keyFn: (message: T) => string
- timeout: number = 60_000
Returns OperatorFunction<T[], T[]>