Function distinctRelaysBatch

  • distinctRelaysBatch<T>(keyFn, timeout?): OperatorFunction<T[], T[]>

  • Type Parameters

    • T extends MessageWithRelay

    Parameters

    • keyFn: ((message: T) => string)
        • (message): string

        • Parameters

          • message: T

          Returns string

    • timeout: number = 60_000

    Returns OperatorFunction<T[], T[]>

Settings

Member Visibility