|
@@ -23,6 +23,7 @@ namespace Playground
|
|
|
await MergeAsync();
|
|
|
await RangeAsync();
|
|
|
await ReturnAsync();
|
|
|
+ await SelectManyAsync();
|
|
|
await SubjectAsync();
|
|
|
await TakeUntilAsync();
|
|
|
await TimerAsync();
|
|
@@ -75,6 +76,15 @@ namespace Playground
|
|
|
await AsyncObservable.Return(42).SubscribeAsync(Print<int>());
|
|
|
}
|
|
|
|
|
|
+ static async Task SelectManyAsync()
|
|
|
+ {
|
|
|
+ var res = from i in AsyncObservable.Range(0, 10)
|
|
|
+ from j in AsyncObservable.Range(i * 10, 10)
|
|
|
+ select i + " -> " + j;
|
|
|
+
|
|
|
+ await res.SubscribeAsync(Print<string>());
|
|
|
+ }
|
|
|
+
|
|
|
static async Task SubjectAsync()
|
|
|
{
|
|
|
var subject = new SequentialSimpleAsyncSubject<int>();
|