class Movie::Streams::Typed::ManualSourceControl(T)

Overview

Materialized control for a manual source blueprint.

Defined in:

movie/streams/core.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(outlet : StageChannel(T)) #

[View source]

Instance Method Detail

def <<(value : T) #

[View source]
def cancel : Nil #

[View source]
def complete #

[View source]
def fail(error : Exception) #

[View source]
def offer(value : T) : QueueOfferResult #

[View source]
def terminal? : Bool #

[View source]