\nIn the last installment about the object model, let's the at the third development style, using .NET's IObservable\/IObserver. IObservable\/IObserver is a new interface in .NET 4.0, the "mirror image" (to use a less controversial term) of IEnumerable\/IEnumerator. A really simplistic way of thinking about it is the Enumerable\/Enumarator is allowing you to pull, IObservable\/IObserver is watching someone push. So supporting IObservable\/IObserver makes it possible to use StreamInsight with .NET classes.\n<\/p>\n
\nWhat they've done in this case is write a generic StreamInsight adapter set over the interfaces. It's called ObservableXXXInputAdapter and ObservableXXXOutputAdapter, where XXX stands for the three StreamInsight event shapes (Point, Edge, and Interval). So there's six classes plus a Factories and Config class for each adapter. Similar in concept to some of the generic text providers they use in the samples, but shipped in a supported library.\n<\/p>\n
\nTo encapsulate the rest of the model there are some ExtensionMethods for the .NET classes that implement IObservables (and a hook for IEnumerables). The main ones are ToObservable and ToCepStream. They work with other extension methods and helper classes to provide for a generic transformation of .NET classes that implement the right interfaces to StreamInsight objects from the familiar Object Model. These extension methods create the (same) StreamInsight object model along the way. Although there is one method currently that may allow you to inject\/use your own Server instance, therefore, being able to navigate the whole Object Model.\n<\/p>\n
\nSo at the end of the day, you work with IObservables\/IObservers (and maybe IEnumerables\/IEnumerators). And the same object model. For a code-assisted review of the main components of the object model, you may now return the the Explicit Server sample. Or for a data-assisted review, a CE database that's been "used" to register CEP objects. \ud83d\ude09<\/p>\n","protected":false},"excerpt":{"rendered":"
In the last installment about the object model, let's the at the third development style, using .NET's IObservable\/IObserver. IObservable\/IObserver is a new interface in .NET 4.0, the "mirror image" (to use a less controversial term) of IEnumerable\/IEnumerator. A really simplistic way of thinking about it is the Enumerable\/Enumarator is allowing you to pull, IObservable\/IObserver is […]<\/p>\n","protected":false},"author":7,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[30,39],"tags":[],"class_list":["post-613","post","type-post","status-publish","format-standard","hentry","category-sql-server-2008-r2","category-streaminsight"],"yoast_head":"\n