Upgrading to futures 0.2

So I had this function that compiled with futures 1.21, but won't anymore after upgrade to v0.2.

Playground link

I saw that method flatten has changed slightly, but it didn't help me much with fixing it.

Change to

where S: Stream<Error = <Self as Stream>::Error>,

and can delete

<S as Stream>::Error: From<<Self as Stream>::Error>,
1 Like