我有以下IObserver的C＃扩展方法。它使我可以通过使用中间主题将LINQ表达式放在它的开头。
/// <summary>
/// Given an IObserver we may wish to build a new IObserver that has LINQ
/// combinators at it's head.
///
/// observer = observer.Wrap(observable=>observable.Where(k=>k>0));
///
/// </summary>
public static IObserver<U>
Wrap<T,U>
( this IObserver<T> This
, Func<IObservable<U>, IObservable<T>> fn
)
{
var s = new Subject<U>();
fn(s).Subscribe(This);
return s;
}
但是当我使用该方法时
[Fact]
public void WrapShouldWrapObservers()
{
var b = new List<int>() { 0, 1, 2,3,4,5 };
var s = new Subject<int>();
var c = new List<int>();
var obs = s.Wrap(observable => observable.Where(k => k > 3));
s.Subscribe(v => c.Add(v));
b.ToObservable().Subscribe(obs);
c.Should().BeEquivalentTo(4, 5);
}
我得到的错误
Error 2 The type arguments for method
ReactiveUI.Ext.IObservableMixins.Wrap<T,U>
( System.IObserver<T>
, System.Func<System.IObservable<U>,System.IObservable<T>>
)
cannot be inferred from the usage. Try specifying the type arguments
explicitly.
当我显式输入args类型时，它就可以工作。
var obs = s.Wrap<int,int>(observable => observable.Where(k => k > 3));
但是从检查来看，如果我将类型args排除在外，则没有任何歧义。这里有什么问题？
- - - - - -回答 - - - - - -
如果我更改测试用例以正确地使用类型，那么很明显问题出在哪里
[Fact]
public void WrapShouldWrapObservers()
{
var b = new List<int>() { 0, 1, 2,3,4,5 };
var s = new Subject<string>();
var c = new List<string>();
var obs2 = s.Wrap<int,string>(observable => observable.Where(k => k > 3).Select(k=>k.ToString()));
s.Subscribe(v => c.Add(v));
b.ToObservable().Subscribe(obs2);
c.Should().BeEquivalentTo("4", "5");
}
无法知道observablelambda的第一个参数应该是什么。Lambda必须返回IObservable，但是可以实现此目的的类型是无限的。
问题在于您lambda中的观察者可以是任何类型。如果仅使用无法转换类型的LINQ运算符，则可以执行以下操作：
public static IObserver<T> Wrap<T> (this IObserver<T> this,
Func<IObservable<T>, IObservable<T>> fn)
{
var s = new Subject<T>();
fn(s).Subscribe(this);
return s;
}
否则，您将必须执行不同的操作，并指定IObserver类型：
var obs = s.Wrap((IObserver<int> observer) => observer.Where(k => k > 3));
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句