Rework the api: receiver + sender, processors: sink, source, seeded source, transformation, async transformation