-record(stream, { work :: fun((fun((gleam@dynamic:dynamic_()) -> nil)) -> gleam@dynamic:dynamic_()), tag :: binary() }).