|
@@ -63,17 +63,6 @@ namespace Playground
|
|
.SubscribeAsync(Print<string>()); // TODO: Use ForEachAsync.
|
|
.SubscribeAsync(Print<string>()); // TODO: Use ForEachAsync.
|
|
}
|
|
}
|
|
|
|
|
|
- static async Task DelayAsync()
|
|
|
|
- {
|
|
|
|
- await
|
|
|
|
- AsyncObservable.Timer(TimeSpan.Zero, TimeSpan.FromSeconds(1))
|
|
|
|
- .Timestamp()
|
|
|
|
- .Delay(TimeSpan.FromMilliseconds(2500))
|
|
|
|
- .Timestamp()
|
|
|
|
- .Select(x => new TimeInterval<long>(x.Value.Value, x.Timestamp - x.Value.Timestamp).ToString())
|
|
|
|
- .SubscribeAsync(Print<string>()); // TODO: Use ForEachAsync.
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
static async Task ConcatAsync()
|
|
static async Task ConcatAsync()
|
|
{
|
|
{
|
|
await
|
|
await
|
|
@@ -86,6 +75,17 @@ namespace Playground
|
|
.SubscribeAsync(Print<int>()); // TODO: Use ForEachAsync.
|
|
.SubscribeAsync(Print<int>()); // TODO: Use ForEachAsync.
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ static async Task DelayAsync()
|
|
|
|
+ {
|
|
|
|
+ await
|
|
|
|
+ AsyncObservable.Timer(TimeSpan.Zero, TimeSpan.FromSeconds(1))
|
|
|
|
+ .Timestamp()
|
|
|
|
+ .Delay(TimeSpan.FromMilliseconds(2500))
|
|
|
|
+ .Timestamp()
|
|
|
|
+ .Select(x => new TimeInterval<long>(x.Value.Value, x.Timestamp - x.Value.Timestamp).ToString())
|
|
|
|
+ .SubscribeAsync(Print<string>()); // TODO: Use ForEachAsync.
|
|
|
|
+ }
|
|
|
|
+
|
|
static async Task MergeAsync()
|
|
static async Task MergeAsync()
|
|
{
|
|
{
|
|
var subject = new SequentialSimpleAsyncSubject<IAsyncObservable<int>>();
|
|
var subject = new SequentialSimpleAsyncSubject<IAsyncObservable<int>>();
|