If I remove wait and future wrapper from

future::done(stream.map(|r| r.data).concat2().wait())

and make the line just `stream.map(|r| r.data).concat2()`m my concat2 gives me an Err of: RpcFailure(RpcStatus { status: Unknown, details: Some("Failed to create subchannel") })