This book contains the documentation of about 80 operators. The RxPY implementation contains about 130 operators. One of the most difficult parts of ReactiveX is using the most suitable operator for a given task. The following list will help you find which operator to use at that time:
To create an observable:
- That emits a single item: just
- That emits a single item returned from a function: Start
- That emits a sequence from an iterable or a generator: from_
- That emits a single item after a specified delay: timer
- That emits a single item from future: from_future
- That emits a sequence of items repeatedly: repeat
- From custom logic: create
- That emits a sequence of consecutive integers: range or from_ (in combination with the Python range function)
- That emits a sequence of items at particular intervals of time: interval
- That completes without...
