subscribe

    1热度

    1回答

    在rxJava 1.x中有可能做这样的事情:也返回Observable<Foo> 我无法找到同样的方法 Observable.<Foo>create(subscriber -> { ... getNewObservable().subscribe(Subscribers.wrap(subscriber)); }) GetNewObservable()在rxJava中2.在

    0热度

    1回答

    感谢您阅读此问题。 无论如何,我已经创建了一个处理项目列表(具有名称和价格)的服务。此服务返回ListComponent订阅的可观察项。 奇怪的是,当我添加一个项目时,订阅工作和ListComponent列表被更新,当我删除一个项目时,订阅不起作用,它不会发送任何错误。 ListComponent: export class ListComponent { listItems: Li

    3热度

    1回答

    嗨,大家好我是否在这里做错了什么?: patchValue的事情工作正常。但FormGroup不会更新视图的输入值.. 我已经尝试过通过使用 私人裁判手动触发它:另外采用.RUN()方法内 私人_ngZone ChangeDetectorRef :NgZone 不起作用 这是我的代码: HTML: <form [formGroup]="addressForm"> <div class

    0热度

    1回答

    有什么办法让这个伪代码起作用吗? private letsSee(): Promise<any> { return new Promise(resolve => { this.someService.someValue.subscribe((nextValue) => { resolve(nextValue); }); }); }

    2热度

    1回答

    大家嗨,我是重新学习Android的工作室,所以不过,我在开发中,我们如何订阅在FCM多个主题一个Android应用程序有一个疑问,这里是我的代码 public void subscribeToPushService() { FirebaseMessaging.getInstance().subscribeToTopic("News"); Log.d("myname",

    1热度

    1回答

    我试图通过“ProductService.ts”中的observables执行一个http调用,导入到它的“ProductComponent.ts”中。我想我已经涵盖了所需的一切,但是我得到以下错误: 错误:由模块'AppModule'声明的意外值'ProductService'。 请有人指出我要去哪里错了吗? 的AppModule: /* angular */ import { Browser

    1热度

    2回答

    我有一个服务来验证我的用户,但我不知道为什么它不会进入subscribe方法,即使我把正确的凭据。 当我把正确证书拿给invalid user这意味着 是isAuthentifiated仍然false。 服务 import { Injectable } from '@angular/core'; import { Http, Response, Headers } from '@angular

    1热度

    1回答

    我订阅了可观察到的这样的功能: public whatever(): Observable<Response> { this.someService.functionReturnsObservable(params) .subscribe( success => { /* stuff to be done after observable's next *

    2热度

    1回答

    当我从TransportComponent发送数据到TruckComponent时,为什么我获得未定义的卡车值? export class TransportComponent { actualTransport: Subject<any> = new Subject(); this.serviceTransport.subscribe((data) => { data.tra

    0热度

    2回答

    我想获得在订阅结束时作为PubNub消息传递的JSON值。这个代码是 package main import ( "encoding/json" "flag" "fmt" "github.com/pubnub/go/messaging" ) type DeployMessages struct { Server string Re