Ingress from Azure Event Hubs - how?

[zemien]

I'm struggling to use Trill in the real world due to lack of samples and documentation about ingress and egress integrations.

I'm looking at how I can use Trill over Event Hubs as both ingress and egress destinations. I realize this is a use case for Stream Analytics, but I want to build something simple by hand to better understand the underlying temporal semantics.

If I understood what I've read so far, the core question is: How do I turn an Event Hub subscription into a TemporalStreamable? Potentially unbounded?