代码之家 › 专栏 › 技术社区 › Vingtoft

角度创建一个可观察的不工作

observable typescript angular

Vingtoft · 技术社区 · 6 年前

在Angular6,我正在创建一个 Injectable 服务。我正在尝试初始化一个 Observable 在 constructor ,请参见下面的简化代码。

问题: 的回调函数 Observable.create 从不执行,也没有错误。为什么是 console.log('authObserver created!') 没打过电话?

import { Observable, Observer } from 'rxjs';

@Injectable()
export class UserLoginService implements OnInit{

  authObserver:Observer;
  authObservable:Observable;

  constructor() {
    this.authObservable = Observable.create((observer: Observer) => {
      this.authObserver = observer;
      console.log('authObserver created!')
    });  
  }    
}

randomCallbackFunction(){
  this.authObserver.next("Button has been clicked");
}

2 回复 | 直到 6 年前

Vikhyath Maiya 6 年前

在您的代码中,我没有看到任何订阅发生。只有在订阅之后才可观察到。试试这个

this.authObservable = Observable.create((observer: Observer) => {
      this.authObserver = observer;
      console.log('authObserver created!')
    });
this.authObservable.subscribe()

Here

Javier Aviles 6 年前

/*
 Create an observable that emits 'Hello' and 'World' on  
 subscription.
*/
 const hello = Rx.Observable.create(function(observer) {
    observer.next('Hello');
    observer.next('World');
 });

 //output: 'Hello'...'World'
  const subscribe = hello.subscribe(val => console.log(val));

Fiddle .

推荐文章

Anjil Dhamala · 在收到特定http状态时重试http调用

6 年前

simonberry · 取消RXJS FlatMap链上的订阅

6 年前

user9487981 · 可以激活防护装置并使用角度为5的可见光

6 年前

makat · 角度5 HTTP请求间隔使用可观察值,而值可能会更改

6 年前

Gissipi_453 · 在RxJava 2中的可观察对象中发出字符串数组时出现“不兼容类型”错误

6 年前

Jake Shakesworth · 如何将一个可观察对象映射到另一个可观察对象

6 年前

Nomura Nori · 许诺仅当使用了4个以上的承诺时,才获得“Access Control Allow Origin”

6 年前

MindlessRouse · 路由解析程序在没有订阅的情况下不触发可观察

6 年前

DevMike · 在角度服务中,如果在可观测范围内使用贴图功能,那么假设贴图功能保证同步是否正确?

6 年前

Arun Prasad E S · 角度5,离子3-【ts】类型“void”不可分配给类型“Observable<Post[]>”

6 年前