Stream Operators

This is a collection of selected rxjs operators for rust standard Stream. Though the operators are coming from the ReactiveX world, I'm not trying to reinvent the observable ecosystem for rust. If you need that, you could use rxrust. For this repom I'm just trying to provide a set of stream operators which could be used for Stream.

Supported Operators

• [x] [debounce_time](https://rxjs.dev/api/operators/debounceTime)
• [x] [distinctuntilchanged](https://rxjs.dev/api/operators/distinctUntilChanged)
• [x] [distinct](https://rxjs.dev/api/operators/distinct)
• [ ] [pluck](https://rxjs.dev/api/operators/pluck): Maps each source value to its specified nested property.
• [ ] [find](https://rxjs.dev/api/operators/find): Emits the first value that matches the condition.
• [ ] [find_index](https://rxjs.dev/api/operators/findIndex): Emits the index of the first value that matches the condition.
• [ ] [group_by](https://rxjs.dev/api/operators/groupBy): Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables, one GroupedObservable per group.
• [ ] [pairwise](https://rxjs.dev/api/operators/pairwise): Emits the previous and current value as a two-element array.
• [ ] [partition](https://rxjs.dev/api/operators/partition): Splits the source Observable into two, one with values that satisfy a predicate, and another with values that don't satisfy the predicate.
• [ ] [sample_time](https://rxjs.dev/api/operators/sampleTime): Samples the source Observable at periodic time intervals, emitting the most recent value emitted by the source Observable since the previous sampling, unless the source has not emitted anything since the previous sampling.
• [ ] [sequence_equal](https://rxjs.dev/api/operators/sequenceEqual): Determines whether two Observables emit the same sequence of items.
• [ ] [throttle_time](https://rxjs.dev/api/operators/throttleTime): Emits a value from the source Observable, then ignores subsequent source values for a duration determined by another Observable, then repeats this process.

Operators supported by tokio-stream

• [x] [every](https://rxjs.dev/api/operators/every): see tokio-stream::StreamExt::all
• [x] [filter](https://rxjs.dev/api/operators/filter): see tokio-stream filter
• [x] [map](https://rxjs.dev/api/operators/map): see tokio-stream map
• [x] [reduce](https://rxjs.dev/api/operators/reduce): see tokio-stream fold
• [x] [concat_with](https://rxjs.dev/api/operators/concatWith): see tokio-stream chain
• [x] [buffertime](https://rxjs.dev/api/operators/bufferTime): see tokio-stream chunkstimeout
• [x] [buffercount](https://rxjs.dev/api/operators/bufferCount): see tokio-stream chunkstimeout
• [x] [merge_with](https://rxjs.dev/api/operators/mergeWith): see tokio-stream merge
• [x] [skip](https://rxjs.dev/api/operators/skip): see tokio-stream skip
• [x] [skipwhile](https://rxjs.dev/api/operators/skipWhile): see tokio-stream skipwhile
• [x] [take](https://rxjs.dev/api/operators/take): see tokio-stream take
• [x] [takewhile](https://rxjs.dev/api/operators/takeWhile): see tokio-stream takewhile
• [x] [timeout](https://rxjs.dev/api/operators/timeout): see tokio-stream timeout
• [x] [delay](https://rxjs.dev/api/operators/delay): see tokio-stream throttle

Operators supported by futures

• [x] [count](https://rxjs.dev/api/operators/count): see futures::StreamExt::count
• [x] [flatmap](https://rxjs.dev/api/operators/flatMap): see futures::StreamExt::flatmap
• [ ] [repeat](https://rxjs.dev/api/operators/repeat): see futures::StreamExt::cycle
• [x] [scan](https://rxjs.dev/api/operators/scan): see futures scan
• [x] [zip_with](https://rxjs.dev/api/operators/zipWith): see futures zip

Usage

See tests for each operator.