ScalusAsyncStreamAdapter

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

Typeclass for building a stream type S[_] from a ScalusAsyncSource.

One instance per stream library, each a handful of lines. The identity instance below means a caller who does not want to choose a library does not have to.

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes
object identity

Members list

Value members

Abstract methods

def fromSource[A](src: ScalusAsyncSource[A]): S[A]