In v0.4, rxRust support convert a cold stream to hot stream. A connectable observable ConnectableObservable was implemented, three operators publish, ref_count and throttle_time was implemented.
For this moment many base work has been done, implement an operator is not a hard work. But ReactiveX has too many operators to implemented, I can't implement it all by my self. I hope you can join me very much, all contributions are welcome.