[RxJS] What RxJS operators are
are Rxjs What Operators
2023-09-14 09:00:53 时间
We have covered the basics of what is Observable.create, and other creation functions. Now lets finally dive into operators, which are the focus of this course. We will see how operators are simple pure functions attached to the Observable type.
var foo = Rx.Observable.of(1, 2, 3, 4, 5); function multiplyBy(num){ // When chaining the subscribe, the source is this keyword const source = this; // Create a observalbe and subscribe const result = Rx.Observable.create(function(observer ){ // source should be immutable, everytime return a new value source.subscribe( (item) => { observer .next(item * num); }, (err) => { observer.error(err); }, () => { observer.complete(); }) }); // Return the observable return result; } // Hack Rx.Observable.prototype.multiplyBy = multiplyBy; var bar = foo.multiplyBy(100); bar.subscribe( function (x) { console.log('next ' + x); }, function (err) { console.log('error ' + err); }, function () { console.log('done'); }, );
If you have many operators in chain like this, with some arguments in between, then, it means that once you subscribe to the observable that this returns (multiplyBy), that will subscribe to bar, which will subscribe to foo, which will subscribe to the source in the multiplyBy function.
相关文章
- ORA-23532: tables with different synchronization mechanisms are in the same group ORACLE 报错 故障修复 远程处理
- ORA-29470: Effective userid or roles are not the same as when cursor was parsed ORACLE 报错 故障修复 远程处理
- ORA-31459: system triggers for DBMS_CDC_PUBLISH package are not installed ORACLE 报错 故障修复 远程处理
- ORA-32305: RepAPI materialized views with user-defined types are not supported ORACLE 报错 故障修复 远程处理
- ORA-39810: Data saves are not allowed when NO_INDEX_ERRORS is specified. ORACLE 报错 故障修复 远程处理
- ORA-55631: Table has columns with data types that are not supported by Flashback Data Archive ORACLE 报错 故障修复 远程处理
- ORA-06595: REF CURSOR parameters are not supported in forwarded RPC calls ORACLE 报错 故障修复 远程处理
- ORA-12528: TNS:listener: all appropriate instances are blocking new connections ORACLE 报错 故障修复 远程处理
- ORA-13346: the coordinates defining an arc are collinear ORACLE 报错 故障修复 远程处理
- ORA-13703: The snapshot pair [string, string] for database_id string and instance_id string are not found in the current repository. ORACLE 报错 故障修复 远程处理