13 lines
377 B
C#
13 lines
377 B
C#
using System;
|
|
using UniRx;
|
|
|
|
namespace SharpUI.Source.Common.Util.Reactive
|
|
{
|
|
public class DelayObserver : IDelayObserver
|
|
{
|
|
public IObservable<long> DelayMilliseconds(long delay, IScheduler scheduler, int takeAmount = 1)
|
|
=> Observable
|
|
.Interval(TimeSpan.FromMilliseconds(delay), scheduler)
|
|
.Take(takeAmount);
|
|
}
|
|
} |