Observable Azure EventHub

That is an observable implementation of Azure EventHubs based transport.

Usage

Exposing an Azure Event Hub instance as a push source:

new EventHubListener(
    "myEventHub", 
    "connectionString", 
    string.Empty, 
    "PartitionA", 
    TimeSpan.FromSeconds(15), 
    10).Dump();

Publish an event to an Azure Event Hub instance:

var publisher = new EventHubPublisher("connectionString", "myEventHub");
publisher.OnNext(new EventData());