首页 > 其他分享 >rxjs

rxjs

时间:2023-04-02 22:34:36浏览次数:46  
标签:console complete err rxjs observer log

 安装

1. web:  https://unpkg.com/[email protected]/dist/cjs/index.js

2. npm:  npm install rxjs   因为rxjs本身就是ts写的,所以没有@types/rxjs 这个类型文件。

github仓库: https://github.com/ReactiveX/rxjs

码云: https://gitee.com/mirrors/rxjs?_from=gitee_search

在webpack中使用: tsconfig.json 中需要配置  "moduleResolution": "node",  否则会报错找不到模块rxjs

在纯粹的typescript中,也需要tsconfig.json 中需要配置  "moduleResolution": "node",  但是虽然不报错,但编译后的js文件却不能正常运行,因为依赖的rxjs代码没有进行打包。

基本使用

 1 import { Observable } from "rxjs";
 2 
 3 const source$ = new Observable(observer => {
 4     console.log('start!');
 5     observer.next(1);
 6     observer.next(2);
 7     observer.complete();
 8     // observer.error({err: 'err'});
 9     return {
10         unsubscribe: () => {
11             console.log('unsubscribe');
12         }
13     }
14 });
15 const subscription = source$.subscribe({
16     next: val => console.log('val=', val),
17     error: err => console.log('err=', err),
18     complete: () => console.log('complete='),
19 });
20 subscription.unsubscribe();

 

end

 

标签:console,complete,err,rxjs,observer,log
From: https://www.cnblogs.com/xiafl/p/17281394.html

相关文章

  • rxjs学习
    基本概念Observable(可观察对象):表示一个概念,这个概念是一个可调用的未来值或事件的集合。相当于Promise对象,内部可以用于执行异步代码,通过调用内部提供的方法将异步代......
  • Rxjs编程系列-基本概念
    Rxjs就是利用javascript实现了响应式编程的概念,利用监听流的模式处理异步操作。1.函数响应式编程函数式编程声明式纯函数数据不可变性响应式编程通过可监听流......
  • Rxjs编程系列-操作符
    定义:一个操作符是返回一个Observable对象的函数,不过,有的操作符是根据其他Observable对象产生返回的Observable对象,有的操作符则是利用其他类型输入产生返回的Observable......
  • rxjs 实现动态异步调度系统
     通过mergemap操作符:实现任务池的限制,通过defer操作符:延迟创建可观察对象实现异步task的队列等待。最终输出结果2,1,3,4符合预期 importReact,{useState,us......
  • rxjs究竟是观察者模式还是发布订阅模式
    rxjs源代码Subscriber.ts,里面对Subscriber的定义:exportclassSubscriberextendsSubscriptionimplementsObserverrxjs里面观察者模式还是发布订阅模式?观察者模式和发......
  • RxJS 系列 – Scheduler
    前言大部分情况下,RxJS都是用来处理异步执行的.比如Ajax,EventListener等等.但其实,它也是可以同步执行的,甚至bydefault它就是同步执行的(下面会给例子). ......
  • RxJS – Custom Operator
    前言虽然RxJS提供了非常多的Operators.但依然会有不够用的时候.这时就可以自定义Operator了. OperatorIsJustaFunction Observable=>ObservableOperato......
  • RxJS 系列 – Subscription & Unsubscribe
    前言前面几篇介绍了概念,Observable,Suject.里头都只提到subscribe订阅.一直没有讲到如果unsubscribe退订. ......
  • [RxJS] merge - build count down example
    import{interval,fromEvent,of,merge,empty}from'rxjs';import{scan,mapTo,takeWhile,takeUntil,tap,startWith,switchMap}from'rxjs/operators';/......
  • Rxjs map, mergeMap 和 switchMap 的区别和联系
    map、mergeMap和switchMap是RxJS中的三个主要运算符,在SAPSpartacus开发中有着广泛的使用场景。mapmap是Observables中最常见的运算符。它的作用与数组中的映......