Browse Source
--------------------------------
using System;
using System.Collections.Generic;
namespace MyApp
{
public interface ISubject<T>
{
}
public class Test<T,TRight,TLeft>
{
public void Foo (IObserver<T> observer)
{
var rightSubs = new List<ISubject<TRight>> ();
var rightVals = new List<TRight> ();
Observer.Create<TLeft> (v => {
ISubject<TRight> rsub = new ReplaySubject<TRight> ();
foreach (var r }, () => sub.OnCompleted ());
}
}
}
------------------------------------
newNRvisualizers
1 changed files with 10 additions and 9 deletions
Loading…
Reference in new issue