Skip to main content

@wildix/xbees-conversations-utils > createRateLimitedStreamProxy

createRateLimitedStreamProxy() function

Creates a proxy around a Stream client that transparently applies rate-limit handling to method calls and recursively wraps returned channel objects with the same behavior.

Signature:

export declare function createRateLimitedStreamProxy(stream: StreamChat<StreamType>, context: LoggerContext & RedisContext): RateLimited<StreamChat<StreamType>>;

Parameters

Parameter

Type

Description

stream

StreamChat<StreamType>

context

LoggerContext & RedisContext

Returns:

RateLimited<StreamChat<StreamType>>