Streaming Data from Database with Observable

suggest change

Assume having a method returning IEnumerable<T>, f.e.

private IEnumerable<T> GetData()
        // return results from database 
    catch(Exception exception)

Creates an Observable and starts a method asynchronously. SelectMany flattens the collection and the subscription is fired every 200 elements through Buffer.

int bufferSize = 200;

    .Start(() => GetData())
    .SelectMany(s => s)
    .Subscribe(items => 
        Console.WriteLine("Loaded {0} elements", items.Count);
        // do something on the UI like incrementing a ProgressBar
    () => Console.WriteLine("Completed loading"));

Feedback about page:

Optional: your email if you want me to get back to you:

Table Of Contents