Skip to main content

isJetStreamRpcMode()

isJetStreamRpcMode(rpc): rpc is { ackExtension?: AckExtensionConfig; concurrency?: number; consume?: Partial<ConsumeOptions>; consumer?: Partial<ConsumerConfig>; management?: EntityManagement; mode: "jetstream"; stream?: Partial<Omit<StreamConfig, "retention">>; subjectPrefix?: string; timeout?: number }

Defined in: src/jetstream.constants.ts:382

Check if the RPC config specifies JetStream mode.

Parameters​

rpc​

RpcConfig | undefined

Returns​

rpc is { ackExtension?: AckExtensionConfig; concurrency?: number; consume?: Partial<ConsumeOptions>; consumer?: Partial<ConsumerConfig>; management?: EntityManagement; mode: "jetstream"; stream?: Partial<Omit<StreamConfig, "retention">>; subjectPrefix?: string; timeout?: number }