pub trait IntoFusion { type Source: Source; // Required method fn fusion(self) -> Stream<Self::Source, Id, Never>; }