.NET – LINQ with RX extension

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

x.Item1

Imports system.reactive.linq

I think the LINQ query language is suitable for IObservable, just like IEnumerable using ReactiveExtensions. I have the following code

Public Sub Foo(source As IObservable(Of Tuple(Of Integer, Integer)))< br /> 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

The IEnumerable version of the code is fine. However, for the LINQ version of Foo (second line)
I got a late binding not allowed error< /p>

x.Item1

When I hover the mouse over x, Intellisense says it is an object type and not a
type tuple. But The operation of the object query version is the same (the first line)
Compile OK. I have already imported

Import s system.reactive.linq

Did I miss another reference?

All the codes in your question apply to me. I did not receive your error.

Maybe try Import System.Reactive, but other than that it looks good.