ScalusAsyncStreamAdapter

scalus.cardano.node.stream.ScalusAsyncStreamAdapter
See theScalusAsyncStreamAdapter companion trait

Attributes

Companion
trait
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Type members

Classlikes

A ScalusAsyncSource is already a stream, so BlockchainStreamProvider[ScalusAsyncSource] is a complete streaming API with nothing beyond the standard library — consume it with a pull() loop, or bridge it wherever. This is the form to reach for in examples, so the first thing a reader meets does not force a choice of stream library.

A ScalusAsyncSource is already a stream, so BlockchainStreamProvider[ScalusAsyncSource] is a complete streaming API with nothing beyond the standard library — consume it with a pull() loop, or bridge it wherever. This is the form to reach for in examples, so the first thing a reader meets does not force a choice of stream library.

Attributes

Supertypes
class Object
trait Matchable
class Any
Self type
identity.type

Givens

Givens

A ScalusAsyncSource is already a stream, so BlockchainStreamProvider[ScalusAsyncSource] is a complete streaming API with nothing beyond the standard library — consume it with a pull() loop, or bridge it wherever. This is the form to reach for in examples, so the first thing a reader meets does not force a choice of stream library.

A ScalusAsyncSource is already a stream, so BlockchainStreamProvider[ScalusAsyncSource] is a complete streaming API with nothing beyond the standard library — consume it with a pull() loop, or bridge it wherever. This is the form to reach for in examples, so the first thing a reader meets does not force a choice of stream library.

Attributes