distinctRelays<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>