How can I implement the equivalent of Rx
combineLatest with futures-rs streams? (http://reactivex.io/documentation/operators/combinelatest.html)
I’d like to get a stream of pairs with the current value of either stream, with the latest value from the other stream. The first value would be emitted only after having one value from each stream.