Fork me on GitHub

Hey all I am trying to chain together some data transformations using pipeline right now I am I am pulling in some JSON via a web request and then adding some fields to the map and then fetching some binary data from URLs in the JSON


the problem I am having is that pipeline, specifically pipeline-async wants to close my channels after use


This feels a bit weird to me and doesn't line up with my conception of how a pipeline works


My current thought process is to either mix channels or spin a new channel for each first web request


Any and all help or guidance is much appreciated!