subscribe
open suspend override fun subscribe(params: <Error class: unknown class>): Flow<<Error class: unknown class>>
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: <Error class: unknown class>, 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().