class Movie::Streams::Typed::Sink(In, Mat)

Overview

Reusable sink blueprint with an input element type and a materialized value, commonly a Future of the sink result.

Defined in:

movie/streams/core.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(&block : AbstractActorSystem, StageChannel(In) -> Mat) #

[View source]

Instance Method Detail

def materialize(system : AbstractActorSystem, inlet : StageChannel(In)) : Mat #

Internal materialization hook used by composition.


[View source]