class Movie::Streams::Typed::StreamRuntimeExtension

Overview

Owns active blueprint edges so ActorSystem shutdown also terminates stream fibers and their materialized futures.

Defined in:

movie/streams/core.cr

Instance Method Summary

Instance methods inherited from class Movie::Extension

start start, stop stop

Instance Method Detail

def register(&cancel : -> Nil) : UInt64 #

[View source]
def stop #
Description copied from class Movie::Extension

Called when the system is shutting down. Override to cleanup resources (close connections, stop services, etc.)


[View source]
def unregister(registration_id : UInt64) #

[View source]