带有Rx扩展的LINQ



i的印象是,linq查询语言为iObservable起作用,就像在反应性延迟有关的情况下一样。我有以下代码

Public Sub Foo(source As IObservable(Of Tuple(Of Integer, Integer)))
  Dim filtered = source.Where(Function(x) x.Item1 > 10).Select(Function(x) x.Item1 + x.Item2)
  Dim filtered2 = From x In source Where x.Item1 > 10 Select x.Item1 + x.Item2
End Sub
Public Sub Bar(source As IEnumerable(Of Tuple(Of Integer, Integer)))
  Dim filtered = source.Where(Function(x) x.Item1 > 10).Select(Function(x) x.Item1 + x.Item2)
  Dim filtered2 = From x In source Where x.Item1 > 10 Select x.Item1 + x.Item2
End Sub

iEnumerable版本的代码还可以。但是对于LINQ版本的Foo(第二行)我在

上遇到了较晚的绑定错误错误
x.Item1

当我徘徊在 x 上类型元组。但是,同一操作的对象查询版本(第一行)编译确定。我导入

Imports system.reactive.linq

我是否缺少另一个参考?

问题中的所有代码对我来说很好。我没有您的错误。

也许也尝试导入System.Reactive,但除此之外,它看起来不错。

相关内容

  • 没有找到相关文章