Tubes.Source

data Source m a

reduce

merge