- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
出于某种原因,我无法在我的任何可观察对象上使用 takeUntil
方法。
我的 IDE (Visual Studio Code) 在我编码时将其显示为有效方法,并且编译良好(从 typescript ),但是当我运行它时,我得到 takeUntil is not a function
在我的任何 observables 上。
我使用的是 rxjs 版本 5.3.0。
我可以通过多种方式实现它,但这可能是最直接的:
let subject:BehaviorSubject<any> = new BehaviorSubject<any>({});
let unsubscribe: Subject<void> = new Subject<void>();
subject.takeUntil(unsubscribe);
老实说,我找不到任何方法来实例化 takeUntil
不会导致该错误的任何内容,但是 IDE 从不提示并且 typescript 总是可以正常编译 - 错误总是发生在浏览器中。
最佳答案
您可能需要导入 takeUntil 运算符:
import 'rxjs/add/operator/takeUntil';
关于javascript - 我所有的 Observables 错误 'takeUntil is not a function',我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43529169/
我想找到所有等于第一个7的项目: val list = List(1,4,5,2,3,5,5,7,8,9,2,7,4) 我的解决方案是: list.takeWhile(_ != 7) ::: List
我有一个服务调用,我每 5 秒检查它是否返回 true 或 false。 notifier(){ return Rx.Observable.of(true) // based on some c
来自 the docs for the TakeUntil operator (强调我的): The TakeUntil subscribes and begins mirroring the sou
向 TakeUntil 添加多个条件的最佳方法是什么?是否只是将 TakeUntil() 调用相互链接起来的问题? IObservable propertyToObserve = ... var ob
在下面的代码示例中,目的是通过向 Subject mid$ 发出 1 来阻止来自 second$ 的事件。 import { Subject, timer } from "rxjs"; import
我订阅了从 NgRx reducer 获取提供程序的订阅。我想用takeUntil()当最终返回一个包含内容的数组时自动关闭订阅: // Fetch providers this.store.pipe
这里没什么太严肃的,只是好奇。 我想举个例子,想出了这段代码: const { Observable, Subject } = Rx const timeout$ = new Subject() co
这里没什么太严肃的,只是好奇。 我想举个例子,想出了这段代码: const { Observable, Subject } = Rx const timeout$ = new Subject() co
我想根据两个条件停止可观察订阅: 时间(使用 import { timer } from 'rxjs/internal/observable/timer'; ) 或 执行状态(使用您将在下面看到的请求
我正在尝试在可观察对象上实现一个辅助方法,该方法返回一个新的可观察对象,在达到超时之前只发出值: implicit class ObservableOps[T](obs: Observable[T])
我想在触发 takeUntil 运算符时执行一个函数(在 ajaxObservable 之外)。 In this way被立即触发,因为我调用了 observer.complete(),但如果我不调用
以下代码定义了我想要的行为(有效)。仅当鼠标按下时才会触发 mousemove 事件。 Rx.Observable.fromEvent(window,"mouseup") .subscribe(
我想使用“takeUntil”运算符以声明式方式取消订阅。但这基本上是行不通的。无论如何我都可以看到控制台输出。 const unsubscribe = new Subject(); function
我有一个未知大小的用户列表。我想要的是查询 first 30 并更新 UI。然后我想通过以 100 为步长的偏移量来查询所有其他用户,直到我得到最后一批用户 - 我应该在这里使用 takeUntil
是否有可能在 takeUntil 运算符中发出满足条件的项目? 最佳答案 嗯,我不确定我是否理解你的问题。是这样的吗? @Test public void tesTakeUntil() { L
我有以下倒计时: userClick=new Subject() resetCountdown(){this.userClick.next()} setCountDown() { let co
因此,如果函数运行的时间足够长以触发在计时器上运行的 takeUntil 函数,我试图让 bool 值为真。 这是代码 start = this.http.get(environment.shocha
我在听 mousemove事件直到mouseup .我正在做 takeUntil . 我的代码: const onMouseMove = fromEvent(window, "mousemov
我有一个简单的 Rxjs 计时器,它会一直运行直到通知程序发出一些东西,直到这里非常基本。 enum TimerResult = { COMPLETE, ABORTED, SK
目前我正在使用 takeWhile (\x -> x /= 1 && x /= 89) l 从列表中获取最多为 1 或 89 的元素。但是,结果不包括这些标记值。 Haskell 是否有一个标准函数可
我是一名优秀的程序员,十分优秀!