I'm working on porting over some Reactive Extension queries to StreamInsight but have run into an issue with an overlapping window query.
I have a source setup in my StreamInsight server and I'm trying to write an overlapping window query like this:
var source = streamInsightServer.GetObservable<EventPattern<MyEventArg>>("EventSource");
var query = source.Window(new TimeSpan(0, 0, 1), new TimeSpan(0, 0, 0, 250));
where source is IQbservable<EventPattern<MyEventArg>>
and query is then IQbservable<IObserverable<EventPattern<MyEventArg>>>
With Reactive the observer was created as follows:
_observer = query.Subscribe(evts =>
{
evts.Count().Subscribe(c =>
{
//push output here
});
});
How can I attach an observer to retrieve the equivalent output from StreamInsight?