Можно ли вызвать методы расширения Rx с помощью lambdas внутри скрипта IronPython?

Question

Может кто-нибудь, пожалуйста, объясните мне это действительно странное наблюдение?

Я пытаюсь вызвать методы расширения Rx изнутри IronPython, и это оказывается просто невозможным. Я открутил его до этого простого примера:

import clr 
clr.AddReference("System.Core") 
from System.Linq import Enumerable 

def process(value): 
    return Enumerable.Select(value, lambda x:x) 

В этом случае мы начинаем с обычного LINQ. Если я вызываю функцию process из моей среды размещения с массивом или любым другим объектом IEnumerable, он работает совершенно нормально.

Итак, я попытался просто заменить ссылки использовать Observable методы расширения, как так:

import clr 
clr.AddReference("System.Reactive.Linq") 
from System.Reactive.Linq import Observable 

def process(value): 
    return Observable.Select(value, lambda x:x) 

В этом случае, если я называю process функцию с IObservable объекта, сбои вызовов с уродливым сообщение об ошибке:

expected IObservable[object], got Select[int, int]

кто попал на что-то вроде этого? Я что-то пропустил? Есть ли какой-то особый случай взлома, чтобы сделать Enumerable работой с делегатами лямбды, что Observable отсутствует? Я должен признать, что я здесь полностью озадачен.

Кстати, так же, как проверки вменяемости, следующий пример работает просто отлично:

import clr 
clr.AddReference("System.Reactive.Linq") 
from System.Reactive.Linq import Observable 

def process(value): 
    return Observable.Sum(value) 

Я хотел оставить его там просто чтобы понять, что проблема на самом деле в методе вызова Observable.Select.

Answer 1

Часть проблемы, я подозреваю, что методы перегружены. Среда выполнения IronPython сделает все возможное, чтобы найти наилучшую перегрузку, но может иногда ошибиться. Возможно, вам придется помогать в устранении перегрузок.

Из сообщения об ошибке кажется, что вы пытаетесь называть его IObservable<int>. Похоже, что перегрузка разрешается здесь и пытается назвать ее Observable.Select<object, object>(). Вам нужно указать некоторые подсказки о том, какую перегрузку вы хотите использовать.

def process(value): 
    return Observable.Select[int,int](value, Func[int,int](lambda x:x))