QubicTypeScript

subscribeTickStream

Emits full tick data including the list of transaction hashes for each tick.

Signature

bob.subscribeTickStream(options?: SubscribeOptions): AsyncIterable<SubscriptionEvent<BobTickData>>

Purpose

Emits full tick data including the list of transaction hashes for each tick.

for await (const event of bob.subscription.subscribeTickStream()) {
  const { tick, epoch, transactions } = event.data
  console.log(`Tick ${tick}: ${transactions.length} transactions`)
}

Parameters

NameTypeDescription
options.signalAbortSignalStops the iteration when aborted

Returns

AsyncIterable<SubscriptionEvent<BobTickData>>

BobTickData fields

FieldTypeDescription
data.ticknumberTick number
data.epochnumberEpoch number
data.transactionsTxHash[]Transaction hashes included in this tick

Stopping a subscription

Pass an AbortSignal to stop without closing the entire client.

const ac = new AbortController()

setTimeout(() => ac.abort(), 60_000)

for await (const event of bob.subscription.subscribeTickStream({ signal: ac.signal })) {
  console.log(event.data.tick)
}

To stop all subscriptions at once, call bob.subscription.close().

On this page