Type Alias Upstream 

type Upstream = dyn Stream<Item = Result<(String, Vec<u8>)>> + Send;