StreamingEmulator

Returns CardanoInfo for this reader.

This is always available synchronously after the reader is constructed. For emulators, this returns the current context. For remote providers like BlockfrostProvider, the CardanoInfo is fetched during async construction.

The same cell subscribeTransactionStatus reads, falling back to the emulator for transactions this provider never observed.

The duality between a one-shot read and its subscription is only worth anything if the two cannot disagree, and they can only be guaranteed not to by reading the same state. A transaction submitted here is Pending then Confirmed in the hub; one that predates this wrapper is answered by the ledger.

Terminal: subscriptions end, and the provider serves no new ones and submits nothing further. A close that left the provider working would leak the very subscriptions it was called to release.

Returns the current slot number.

The tip as the stream sees it — synthetic block height, and the emulator's own slot.

Returns the ExecutionContext captured by this reader.

This is used internally by default method implementations. External code can use this when working with Futures returned by reader methods, or provide their own.

Fetches the latest protocol parameters from the network.

Find UTxOs using a type-safe query.

Look up a datum by its hash. Returns None if unknown.

Advance the tip without a transaction.

What this provider can do. The only thing an implementation declares; per-request support is derived from it by SubscriptionSupport.of.

Submits a transaction to the network.

Latest-value stream of protocol parameters: the current value on subscribe, then changes.

Latest-value stream of chain-tip updates — newer wins, so a subscriber always sees the most recent tip when it pulls rather than a backlog of stale ones.

Latest-value stream of one transaction's status, following it through the mempool into a block — and back out again if a rollback orphans it.

Find a single UTxO by its transaction input.

Find all UTxOs at the given address.

Find UTxOs by a set of transaction inputs (fails with NotFound if not all are found).

Map over the Future effect using this reader's captured ExecutionContext.

Poll for transaction confirmation.

Default implementation for emulators: a single check is sufficient since confirmation is instant.

Query UTxOs using a lambda DSL.

Translates the lambda to a UtxoQuery at compile time and returns a builder that can be further configured before execution. Effect-polymorphic — the resulting .execute() returns the reader's own F[Either[UtxoQueryError, Utxos]], so the same call shape works on Future-typed providers (Blockfrost, JS) and direct-style providers (ox Id).

Example:

// Simple query — execute immediately
reader.queryUtxos { u =>
 u.output.address == myAddress
}.execute()

// With pagination and minimum total
reader.queryUtxos { u =>
 u.output.address == myAddress && u.output.value.hasAsset(policyId, assetName)
}.minTotal(Coin.ada(100)).limit(10).execute()

Supported expressions:

• u.output.address == addr — query by address
• u.input.transactionId == txId — query by transaction
• u.output.value.hasAsset(policyId, assetName) — query/filter by asset
• u.output.value.coin >= amount — filter by minimum lovelace
• u.output.hasDatumHash(hash) — filter by datum hash
• && — AND combination
• || — OR combination

Submit a transaction and poll until confirmed.

Default implementation composes submit and pollForConfirmation.

Subscribe with default options.

Subscribe with default options.

Subscribe with default options.