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());