Compartir a través de

Soporte API con IObservable e IEnumerable en StreamInsight

  • Artículo

En este tema se resumen las características de API en StreamInsight que admiten orígenes y receptores de eventos que implementan las interfaces IObservable o IEnumerable.

Soporte API con una entrada observable y enumerable

Las características de API siguientes admiten orígenes del evento que implementan las interfaces IObservable o IEnumerable.

Crear entradas

Crear entradas enlazadas

Cree un flujo de entrada enlazado a una aplicación mediante una de las sobrecargas siguientes para el método Create de la clase CepStream<(Of <(<'TPayload>)>)>.

Crear entradas a partir de una entrada observable

Convierta un origen del evento de IObservable en un flujo de entrada mediante una de las sobrecargas siguientes para el método ToStream de la clase ObservableCepStream.

Crear entradas a partir de una entrada enumerable

Convierta un origen del evento de IEnumerable en un flujo de entrada mediante una de las sobrecargas siguientes para el método ToStream de la clase CepStream.

Describir las características temporales

Describa las características temporales de los datos de origen mediante uno de los elementos auxiliares siguientes en la clase AdvanceTimeSettings.

Asignar la entrada a eventos de punto, de intervalo y perimetral

Asigne los datos de entrada a eventos de punto, de intervalo y perimetral mediante los métodos siguientes en una expresión pasada a una sobrecarga del método ToStream.

Asignar la entrada a eventos de punto

Asigne los datos de entrada a eventos de punto y los eventos CTI correspondientes mediante los métodos siguientes de la clase PointEvent o PointEvent<(Of <(<'TPayload>)>)> en una expresión pasada a una sobrecarga del método ToStream.

Asignar la entrada a eventos de intervalo

Asigne los datos de entrada a eventos de intervalo y los eventos CTI correspondientes mediante los métodos siguientes de la clase IntervalEvent o IntervalEvent<(Of <(<'TPayload>)>)> en una expresión pasada a una sobrecarga del método ToStream.

Crear eventos perimetrales

Asigne los datos de entrada a eventos perimetrales y los eventos CTI correspondientes mediante los métodos siguientes de la clase EdgeEvent o EdgeEvent<(Of <(<'TPayload>)>)> en una expresión pasada a una sobrecarga del método ToStream.

Soporte API con una salida observable y enumerable

Las características de API siguientes admiten receptores de eventos que implementan las interfaces IObservable o IEnumerable.

Crear salidas

Convierta un flujo de eventos en una salida de IObservable para una forma de evento concreta mediante uno de los métodos siguientes de la clase ObservableCepStream.

Convierta un flujo de eventos en una salida de IEnumerable para una forma de evento concreta mediante uno de los métodos siguientes de la clase CepStream.

Asignar la salida

Asignar una salida observable

Use los métodos siguientes de ObservableCepStream para asignar una salida observable.

Asignar una salida enumerable

Use los métodos siguientes de CepStream para asignar una salida enumerable.

Interfaces extendidas para receptores de eventos

Los métodos descritos anteriormente para crear y filtrar la salida devuelven receptores de eventos que implementan interfaces que extienden las interfaces IObservable y IEnumerable base. En concreto, las interfaces extendidas permiten proporcionar un nombre de consulta con fines de depuración.