JetstreamApi

class JetstreamApi(httpClient: HttpClient) : JetstreamInterface

Implementation to interact with a hosted Jetstream service.

Constructors

constructor(hostName: String)

Construct a new instance using a free-form hostName.

constructor(host: JetstreamHost)

Construct a new instance using a well-known JetstreamHost instance.

constructor()

Construct a new instance that connects to the JetstreamHost.JETSTREAM_1_US_EAST instance.

constructor(httpClient: HttpClient)

Construct a new instance using an existing HttpClient.

open suspend override fun subscribe(params: <Error class: unknown class>): Flow<<Error class: unknown class>>

open suspend override fun subscribe(params: <Error class: unknown class>, block: suspend SubscriptionContext.() -> Unit)

Subscribe to a Jetstream firehose with the given params.