observable

    0热度

    3回答

    我正在重构遗留代码以使用Android Architecture Components,并在一种存储库模式中设置房间数据库和排空请求。 因此,演示文稿/域层会要求存储库让LiveData-Objects观察或告诉他与服务器同步,然后删除旧的数据库条目并从服务器中重新提取所有当前数据条目。 我已经编写了同步部分的测试,所以我相信,对象会被正确提取并插入数据库。但是当编写一个测试来观察那个db表的条目

    0热度

    1回答

    我正在使用HttpInterceptor重新发送带有令牌的请求,以防它们返回401. 在我刚刚使用缓存的令牌之前,这很有效。由于Firebase标记似乎没有自动刷新(尽管使用forceRefresh),我现在试图在拦截器类中实时获取新标记。问题是现在请求没有被重新发送。 这里是我的全部拦截: export class CustomHttpInterceptor implements HttpInt

    1热度

    2回答

    我正在创建一个考试应用程序,因此当时间到了时,我需要一个视图控制器来弹出以告诉用户他已超出他的时间并将他/她带到结果页面! ! 但取消订阅计时器后,我的函数进入循环! 请帮我看看这个.. 我的代码在下面! minutesDisplay: number = 0; hoursDisplay: number = 0; secondsDisplay: number = 0; sub: Subscr

    0热度

    3回答

    我想创建一个模拟服务如下。 我的服务是一样 import { Injectable } from '@angular/core'; import { URLSearchParams } from '@angular/http'; import { Observable } from 'rxjs/Observable'; import { Config } from '../../sh

    2热度

    1回答

    我收到以下错误消息。 类型'响应'的参数不能分配给'响应'类型的参数。 类型'响应'中缺少属性'body'。 我正在运行的代码依赖于observables。 public register(reporter: Reporter): Observable<Response> { const content = JSON.stringify(reporter); const he

    0热度

    1回答

    我试图执行更硬的类型编码结构,以下智能感知信息引起了我的好奇心。现在 (method) Observable.subscribe(next?: (value: Response) => void, error?: (error: any) => void, complete?:() => void): Subscription (+2 overloads) ,我做明白它说但我很惊讶为什么error

    4热度

    3回答

    在一个C#控制台应用程序中,使用System.Reactive.Linq,我试图做一个observable,其中每个项目是由另一个observable进行某些处理的字符串结果。 我用字符串和字符创建了一个简单的repro。 警告,这个例子完全是CONTRIVED,重点是嵌套的.Wait()挂起。 class Program { static void Main(string[] arg

    -2热度

    1回答

    阵列 我已经实现在服务的阵列的接口: import { Injectable } from '@angular/core'; import { Observable } from 'rxjs'; interface Artwork { artTitle: string; slideUrl?: string; } let Artwks: Artwork [] =

    3热度

    1回答

    我正在尝试编写一个自定义代理,它将清理Kotlin类中数据绑定的语法。这将消除为每个我想要观察的属性定义自定义getter和setter的需要。 在科特林的标准实现看起来如下: class Foo : BaseObservable() { var bar: String @Bindable get() = bar set(value) { bar

    1热度

    1回答

    我在接收可观察值的组件angular中有一个函数。我需要修改observable内的对象,然后再次将其放回到observable中并返回。这是我的代码到目前为止: myImmobili = Observable<Valutazione[]>; newImmobile(immobili: Observable<Valutazione[]>) { immobili.subscribe(