专栏首页Jerry的SAP技术分享rxjs里的Observable对象如何消费

rxjs里的Observable对象如何消费

测试代码:

import { of } from 'rxjs';
import { Injectable } from '@angular/core';

@Injectable()
export class JerrySandBoxService{
    name = 'Jerry';
    print(){
        const myObservable = of(1, 2, 3);

        // 创建一个观察者对象-Observer(处理next、error、complete回调)
        const myObserver = {
         next: x => console.log('Observer got a next value: ' + x),
        error: err => console.error('Observer got an error: ' + err),
        complete: () => console.log('Observer got a complete notification'),
    };

        // 通过Observable的subscribe函数,观察者去订阅可观察者的消息
        myObservable.subscribe(myObserver);
    }
}

调用Observable构造器,传入的数组被subscribeToArray再包装一层:

Observable的构造函数,接受的参数是另一个函数:

最后of返回的是一个observable对象。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • rxjs里的Observable对象subscribe方法的执行原理

    调用Observable的subscribe方法,传入一个包含回调函数的observer对象:

    Jerry Wang
  • SAP Customer Data Cloud的Audit log设置

    Jerry Wang
  • SAP Spartacus应用入口的模块加载单步调试

    看看我的app module,里面有两个export的对象:DebugConfig和AppModule:

    Jerry Wang
  • rxjs里的Observable对象subscribe方法的执行原理

    调用Observable的subscribe方法,传入一个包含回调函数的observer对象:

    Jerry Wang
  • 斯坦福大学密码学-基于Diffie-Hellman 的公钥加密 12

    Bob用Alice的公钥加密完 后,Alice就可以用自己的私钥解出对称密钥,读取文件。

    静怡
  • 线性代数基础之矩阵乘法

    概述 最近在回顾偏微分方程、线性代数和统计学方面的知识,为了方便自己后期查询。对一些数学思想和思维进行了深刻探讨。一些思想对自己解决问题和思路很有帮助,所以就记...

    BrianLv
  • 基于web页面开发串口程序界面---初衷

    在用串口开发和硬件设备通讯的程序,主要是对机器的参数设置以及读取机器数据(通常为传感器测量数据),经常要需要串口调试助手。为了让自己的硬件产品方便日常配置参数和...

    MiaoGIS
  • QNX4系统启动过程

    嵌入式系统的启动都是类似的,先启动一个boot程序,然后又boot控制系统的进一步加载运行.

    李小白是一只喵
  • 盗链问题何时休,网站如何配置防盗链功能有效杜绝盗图行为 原创 配置 AppNode

    奇梦
  • windows服务器云盘卸载失

    如果windows服务器内执行了云盘脱机操作依旧无法解挂磁盘,可以查看下系统日志,确定是否有进程干预了磁盘的解挂操作。如下图所示,是否有警告的日志。

    张晗

扫码关注云+社区

领取腾讯云代金券