selected rxjs operators implemented for standard Rust Stream - View it on GitHub