subscribe

open suspend override fun subscribe(params: SubscribeQueryParams): Flow<SubscribeMessage>

Subscribe to a Jetstream firehose with the given params.

Messages will be emitted as they are received via the returned Flow.


open suspend override fun subscribe(params: SubscribeQueryParams, block: suspend SubscriptionContext.() -> Unit)

Subscribe to a Jetstream firehose with the given params.

Messages will be emitted as they are received via messages. Options that affect the messages being received can be updated via updateSubscription().