|
@@ -1,16 +1,22 @@
|
|
using System;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Linq;
|
|
|
|
+using System.Reactive.Disposables;
|
|
using System.Reactive.Linq;
|
|
using System.Reactive.Linq;
|
|
|
|
+using System.Reactive.Subjects;
|
|
using System.Text;
|
|
using System.Text;
|
|
|
|
|
|
namespace CommonCodeInPcl
|
|
namespace CommonCodeInPcl
|
|
{
|
|
{
|
|
public class Class1
|
|
public class Class1
|
|
{
|
|
{
|
|
|
|
+ ISubject<Class1> subject;
|
|
|
|
+ IDisposable disposable = Disposable.Empty;
|
|
public static IObservable<int> GetFoo()
|
|
public static IObservable<int> GetFoo()
|
|
{
|
|
{
|
|
|
|
+
|
|
return Observable.Interval(TimeSpan.FromMinutes(1)).Select(_ => 3);
|
|
return Observable.Interval(TimeSpan.FromMinutes(1)).Select(_ => 3);
|
|
|
|
+
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|