JetstreamApi

Implementation to interact with a hosted Jetstream service.

Constructors

constructor(httpClient: HttpClient)

Construct a new instance using an existing HttpClient.

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.

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

Subscribe to a Jetstream firehose with the given params.