Reactive polling

gistfile1.txt

var ticks = Observable.Interval(TimeSpan.FromSeconds(_settings.IntervalInSeconds));

var pollResults = Observable.Create<PollResult>(observer =>
{
    var results = // do request
    
    foreach (var result in results) 
      observer.OnNext(new PollResult(result));
    
    return Disposable.Empty;
});

ticks.Subscribe(tick => pollResults.Subscribe(pollResult =>
{
   // handle result
}));

I don't know the exact language/library, but I would try:
var poller = ticks.map(tick => return // do request)

If do request returns an Observable, you can also use flattenMap
var poller = ticks.flattenMap(tick => return Observable.create...)