Partager via

Prise en charge API pour IObservable et IEnumerable dans StreamInsight

  • Article

Cette rubrique résume les fonctions API de StreamInsight prenant en charge les sources et récepteurs d'événements qui implémentent les interfaces IObservable ou IEnumerable.

Prise en charge API pour les entrées observables et énumérables

Les fonctions d'API suivantes prennent en charge les sources d'événements qui implémentent les interfaces IObservable ou IEnumerable.

Création d'entrées

Création d'entrées liées

Crée un flux d'entrée lié à une application à l'aide de l'une des surcharges suivantes pour la méthode Create de la classe CepStream<(Of <(<'TPayload>)>)>.

Création d'entrées à partir d'une entrée observable

Traduit une source d'événement IObservable en un flux d'entrée à l'aide de l'une des surcharges pour la méthode ToStream de la classe ObservableCepStream.

Création d'entrées à partir d'une entrée énumérable

Traduit une source d'événement IEnumerable en un flux d'entrée à l'aide de l'une des surcharges pour la méthode ToStream de la classe CepStream.

Description des caractéristiques temporelles

Décrit les caractéristiques temporelles des données sources à l'aide de l'une des applications auxiliaires sur la classe AdvanceTimeSettings.

Mappage d'entrées à des événements point, intervalle et session

Mappe les données d'entrée à des événements point, intervalle et session à l'aide de l'une des méthodes suivantes dans une expression passée à une surcharge de la méthode ToStream.

Mappage d'entrées à des événements point

Mappe les données d'entrée à des événements point et aux événements CTI correspondants à l'aide des méthodes suivantes de la classe PointEvent ou PointEvent<(Of <(<'TPayload>)>)> dans une expression passée à une surcharge de la méthode ToStream.

Mappage d'entrées à des événements intervalle

Mappe les données d'entrée à des événements intervalle et aux événements CTI correspondants à l'aide des méthodes suivantes de la classe IntervalEvent ou IntervalEvent<(Of <(<'TPayload>)>)> dans une expression passée à une surcharge de la méthode ToStream.

Création d'événements session

Mappe les données d'entrée à des événements session et aux événements CTI correspondants à l'aide des méthodes suivantes de la classe EdgeEvent ou EdgeEvent<(Of <(<'TPayload>)>)> dans une expression passée à une surcharge de la méthode ToStream.

Prise en charge API pour les sorties observables et énumérables

Les fonctions d'API suivantes prennent en charge les récepteurs d'événements qui implémentent les interfaces IObservable ou IEnumerable.

Création de sorties

Traduit un flux d'événements en une sortie IObservable pour une forme Événement spécifique à l'aide de l'une des méthodes suivantes de la classe ObservableCepStream.

Traduit un flux d'événements en une sortie IEnumerable pour une forme Événement spécifique à l'aide de l'une des méthodes suivantes de la classe CepStream.

Mappage de sorties

Mappage d'une sortie observable

Utilise les méthodes ObservableCepStream suivantes pour mapper une sortie observable.

Mappage d'une sortie énumérable

Utilise les méthodes CepStream suivantes pour mapper une sortie énumérable.

Interfaces étendues pour récepteurs d'événements

Les méthodes de création et de filtrage de sorties décrites ci-dessus retournent des récepteurs d'événements implémentant des interfaces qui étendent les interfaces IObservable et IEnumerable de base. Les interfaces étendues vous permettent de spécifier un nom de requête à des fins de débogage.