class Movie::Streams::Typed::DeliveryControl

Overview

Shared cancellation signal for a collect sink and its materialized handle. Closing the signal wakes a delivery fiber even when it is waiting on an unbuffered output channel.

Defined in:

movie/streams_typed.cr

Instance Method Summary

Instance Method Detail

def stop #

[View source]
def stop_signal : Channel(Nil) #

[View source]