- 综合排序
- 最热优先
- 最新优先
- 来自专栏全栈修仙之路
创建 Observable
它是 Observable 类的静态属性 —— static create: Function，也是创建 Observable 对象的工厂方法。 import { Observable } from "rxjs"; const observable$ = Observable.create(observer => { observer.next 具体示例如下： import { Observable } from "rxjs"; const observable$ = Observable.create(observer => { observer.next error —— 当 Observable 内发生错误时，error 方法就会被调用。 complete —— 当 Observable 数据终止后，complete 方法会被调用。 接下来我们来看个具体示例： import { Observable } from "rxjs"; const observable$ = Observable.create(observer => {
1.5K10发布于 2019-11-05 - 来自专栏Java与Android技术栈
Cold Observable 和 Hot Observable
Observable的分类 Observable 有 Cold 和 Hot 之分。 ? 尽管 Cold Observable 很好，但是对于某些事件不确定何时发生以及不确定 Observable 发射的元素数量，那还得使用 Hot Observable。 Cold Observable 如何转换成 Hot Observable？ 1. 同时它又作为Observable 转发或者发送新的事件，让 Cold Observable 借助 Subject 转换为 Hot Observable。 Hot Observable 如何转换成 Cold Observable？ 1.
1.2K20发布于 2018-08-24 - 来自专栏全栈修仙之路
RxJS Observable
发布：Observable 通过回调 next 方法向 Observer 发布事件。 自定义 Observable 如果你想真正了解 Observable，最好的方式就是自己写一个。 当我们订阅新返回的 Observable 对象时，它内部会自动订阅前一个 Observable 对象。 Hot Observable vs Cold Observable Hot Observable Hot Observable 无论有没有 Subscriber 订阅，事件始终都会发生。 当 Hot Observable 有多个订阅者时，Hot Observable 与订阅者们的关系是一对多的关系，可以与多个订阅者共享信息。 Observable vs Promise Observable（可观察对象）是基于推送（Push）运行时执行（lazy）的多值集合。
3.3K20发布于 2019-11-05 - 来自专栏finleyMa
说清 Observable
本节会讲到 什么是观察者（Observer）模式及代码实现 什么是 Iterator (迭代器) 模式及代码实现 什么是 Observable 观察者模式 发布—订阅模式又叫观察者模式，它定义对象间的一种一对多的依赖关系 当我们把一个字串丢进 getNumbers 函式时，并没有马上运算出字串中的所有数字，必须等到我们执行 next() 时，才会真的做运算，这就是所谓的延迟运算(evaluation strategy) Observable image.png Observable 其实就是这两个 Pattern 思想的结合，Observable 具备生产者推送数据的特性，同时能像数组，拥有数组处理数据的方法(map, filter 下节讲 如何创建 Observable 。 参考： http://es6.ruanyifeng.com/#docs/iterator
69820发布于 2018-12-27 - 来自专栏Android开发经验分享
Observable subscribe流程介绍
转载请以链接形式标明出处： 本文出自:103style的博客 本文基于 RxJava 2.x 版本 ---- 我们直接看Observable的subscribe方法 public final
52710编辑于 2022-12-19 - 来自专栏江歌闲谈
MobX 源码解析-observable
observable 首先，看入口文件，mobx-source -> mobx.js，发现observable，action，runInAction 等其他方法都是从 internal 引入的。 /api/observable"; 然后看 api/observable 这个文件，发现 export const observable = createObservable; function createObservable observable.object(v, arg2, arg3) : Array.isArray(v) ? observable.array(v, arg2) : isES6Map(v) ? 根据变量不同类型，调用 observable 的不同参数，如 object, array 来进行劫持。
96400发布于 2021-06-14 - 来自专栏我只不过是出来写写iOS
RxSwift介绍（二）——Observable
Observable介绍 Observable<T>类是RxSwift框架的基础。 贴一个最基本的Observable的创建与订阅代码 //创建Observable let ob = Observable<Any>.create { (anyObser Observable创建 以下列出Observable各种创建的方法，以及对应不同的使用场景 just方法 该方法通过传入一个默认值来初始化 let createJustObservable 来查看结果 var isOdd = true let factory: Observable<Int> = Observable .deferred 当没有订阅者时，Observable 对象不会发送通知。
1.9K20发布于 2019-04-02 - 来自专栏亦枫的大佬之路
Vue中的Observable()
，就会遇到多组件状态共享的情况， Vuex当然可以解决这类问题，不过就像 Vuex官方文档所说的，如果应用不够大，为避免代码繁琐冗余，最好不要使用它，今天我们介绍的是 vue.js 2.6 新增加的 Observable 简单来说，复杂的项目用vuex，简单点的项目用Vue.observable()。 定义： observable()方法，用于设置监控属性，这样就可以监控viewModule中的属性值的变化，从而就可以动态的改变某个元素中的值，监控属性的类型不是变量而是一个函数，通过返回一个函数给viewModule 2.写 var b=ko.observable(“数据内容”);//该方法会设置b属性的当前值，并设置该属性为监控属性，实际上就是把一个函数赋值给该属性，通过该方法可以让属性成为监控属性，监测属性值的变化 实例： 1.创建store.js 最好和main.js平级创建文件 import Vue from 'vue' export const store = Vue.observable({ name
1.5K20发布于 2020-03-19 - 来自专栏程序人生
谈谈FRP和Observable（二）
我们拿Observable和设计模式来类比。 你可以很容易把C#的例子转换成javascript的例子，你也可以在前端使用javascript处理Observable，在后端使用java处理Observable，这便是 ? 另外一些读者的担心是Observable是不是只能应用在很小的一些场景下才能应用。今天的文章本来就计划给出更多的例子来探讨FRP和Observable的应用场景。 do 在Observable里，遇到上游的Observable传过来的内容，不做任何处理，向下游传递，同时，在函数体内做相应的副作用的处理。 Observable提供了一些手段，可以参考： 你可以concatAll，如果多个Observable的数据是要保留先后顺序的（类比priority queue） 也可以mergeAll，如果多个Observable
1.1K50发布于 2018-03-06 - 来自专栏用户9379088的专栏
Rxjs源码解析（一）Observable
从 new Observable 开始import { Observable } from 'rxjs'const observable = new Observable<number>(subscriber () 方法创建了一个可观察对象 observable，然后通过 subscribe 方法订阅这个observable，订阅的时候会执行在 new Observable时候传入的函数参数，那么就来看下 new Observable到底做了什么// /src/internal/Observable.tsexport class Observable<T> implements Subscribable<T> : Operator<T, R>): Observable<R> { const observable = new Observable<R>(); observable.source = this ; observable.operator = operator; return observable;}lift通过 new Observable返回新的 observable，并且标记了 source
2.1K50编辑于 2022-07-01 - 来自专栏finleyMa
创建 Observable
; 使用 RxJS 的话，创建一个 observable 来代替（基于最新的Rxjs6版本写法） <script src='. ; </script> 上面例子中的fromEvent就是基于Event 建立 <em>Observable</em>，fromEvent 的第一个参数要传入 DOM 对象，第二个参数传入要监听的事件名。 创建 <em>Observable</em> 有很多操作符 ? 订阅一个 <em>Observable</em> 就像是执行一个 function <em>observable</em>.subscribe( observer ) 使用from操作符将对象、字符串，数组，promise 等其他类型转换为<em>Observable</em>，请自己敲一遍看结果。
98910发布于 2018-12-27 - 来自专栏云原生应用工坊
Observable Platform 5：PromQL, LogQL and TraceQL
在PromQL、LogQL和TraceQL之前，业界在查询和分析监控指标、日志和链路时使用了不同的方法和工具。这些方法和工具通常会因技术和需求的演变而变化，以下是在之前常见的一些方法：
65710编辑于 2023-12-20 - 来自专栏学海无涯
iOS26适配指南之@Observable Object
介绍 UIKit 支持@Observable类型。 修饰的类型必须是类而不能是结构体。 当@Observable中的数据发生变化时，layoutSubviews()与viewWillLayoutSubviews()方法会自动调用。 案例 import UIKit // MARK: - PhoneModel @Observable class PhoneModel { var name: String var osName
67700编辑于 2025-06-25 - 来自专栏云原生应用工坊
Observable Platform-3: Application System Monitoring Items
When discussing monitoring and alerting from a container application perspective, there are several key points to consider. Traditional host-based monitoring approaches, such as utilization and load monitoring, may no longer be suitable in a dynamic, multi-replica Pod environment. This is due to the dynamic nature and elasticity of application services in containerized and microservices architectures.
43010编辑于 2023-12-13 - 来自专栏全栈程序员必看
java observable_java primitive type
SortedSet 接口主要用于排序操作，即实现此接口的子类都属于排序的子类 SortedSet 接口定义：
45530编辑于 2022-11-19 - 来自专栏掘金安东尼
继续解惑，异步处理 —— RxJS Observable
将上面的过程转化为代码： import { Observable } from 'rxjs/Rx'; let sub = Observable .interval(1000) .map （分离材料与加工机器，就是分离 Observable 和 Subscribe） 接下来，我们再具体看看 Observable 细节： 创建 const Rx = require('rxjs/Rx') ('bar'), 1000); }); 我们可以调用 Observable.create 方法来创建一个 Observable，入参是 observer，在函数内部通过调用 observer.next( ) 便可生成有一系列值的一个 Observable。 多播（即一个Observable，多个subscribe）： ---- 以上就是关于 RxJS Observable 进一步在概念上的解惑~~ 觉得还不错，点个赞吧 更多推荐阅读： RxJS——给你如丝一般顺滑的编程体验
1.7K30编辑于 2022-09-19 - 来自专栏程序人生
谈谈FRP和Observable（一）
而Observable将这个概念延伸到了异步处理当中。 任何第三方可以subscribe这个Observable，获取其数据。先不说废话，我们看一个Observable的例子（RxJs）： ? 在使用方面，Observable是lazy的。cold Observable只有在 subscribe 的那一刻才被调用，hot Observable只有在 connect 发生的那一刻才开始服务。 （要访问这段代码，请移步：jsbin.com/duqaya/5/edit） 至于什么是cold Observable，什么是hot Observable，聪明如你看了代码也猜了个八九不离十：一个Observable 我们以Observable一个经典的例子来结束本文： ?
1.2K70发布于 2018-03-28 - 来自专栏finleyMa
Observable 和 数组的区别
Observable 和 数组都有filter, map 等运算操作operators，具体的区别是什么？ 主要是两点： 延迟运算 渐进式取值 延迟运算 延迟运算很好理解，所有 Observable 一定会等到订阅后才开始对元素做运算，如果没有订阅就不会有运算的行为 var source = Rx.Observable.from ([1,2,3,4,5]); var example = source.map(x => x + 1); 上面这段代码因为 Observable 还没有被订阅，所以不会真的对元素做运算，这跟数组的操作不一样 image.png Observable operator 的运算方式跟数组的是完全的不同，虽然 Observable 的 operator 也都会回传一个新的 observable，但因为元素是渐进式取得的关系 image.png 渐进式取值的观念在 Observable 中其实非常的重要，这个特性也使得 Observable 相较于 Array 的 operator 在做运算时来的高效很多，尤其是在处理大量资料的时候会非常明显
65320发布于 2018-12-27 - 来自专栏贺贺的前端工程师之路
Angular2 之 Promise vs Observable
调用情况 Observable 还具有可订阅性，对于 Cold Observable 而言，只有订阅后才开始起作用 Promise 一经产生便开始起作用 总结：在视频中有详细的介绍。 Observable，由于可以有任意多个数据，因此需要一个额外的状态来表示完成，一经完成后便不能再产生数据。 对于变换，（最简单的方式）需要使用 .map 方法，用来把 Observable 中的某个元素转换成另一种形式。 对于组合，（最简单的方式）需要使用 .mergeMap 方法，用来把两个 Observable 整合为一个 Observable； 对于使用，我们需要使用 .subscribe 方法，用来通知 Observer 当然还可能有另一类运算符，比如 .toPromise 等，这些并不返回 Observable 的方法其实本身并不是一个运算符，仅仅是对 Observable 的原型扩展。
86020发布于 2018-08-21 - 来自专栏JSCON简时空
用故事解读 MobX源码（五） Observable
将与 observable 的源码 相关的源码稍微整理，就是如下的形式： var observable = createObservable; // 使用“奇怪”的方式来扩展 observable 函数的功能 'observable name:', observable.name); console.log(Object.getOwnPropertyNames(observable)); 从以下控制台输出的结果来看 示例二：observable.box(primitive) 能行，observable(primitive) 却会报错 var pr1 = observable.box(2); console.log( 6、小测试 请分析 observable.map 和 observable.array 的源码，看看它们和 observable.object 方法之间的差别在哪儿。 observable 方法了，那么 observable.box 方法存在的意义是什么？
1.1K20发布于 2020-04-01
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号