C# Language Tutorial => Streaming Data from Database with Observable

Example

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

private IEnumerable<T> GetData()
{
    try 
    {
        // return results from database 
    }
    catch(Exception exception)
    {
        throw;
    }
}

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;

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

PDF - Download C# Language for free

Previous Next

C# Language

Fastest Entity Framework Extensions

Example

Got any C# Language Question?

C# Language

C# Language Reactive Extensions (Rx) Streaming Data from Database with Observable

Fastest Entity Framework Extensions

Example

Got any C# Language Question?