Classe ObservableCepStream

Fournit le la prise en charge des récepteurs d'événements qui implémentent l'interface IObservable.

Hiérarchie d'héritage

System.Object
  Microsoft.ComplexEventProcessing.Linq.ObservableCepStream

Espace de noms :  Microsoft.ComplexEventProcessing.Linq
Assembly :  Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)

Syntaxe

'Déclaration
<ExtensionAttribute> _
Public NotInheritable Class ObservableCepStream
'Utilisation
public static class ObservableCepStream
[ExtensionAttribute]
public ref class ObservableCepStream abstract sealed
[<AbstractClassAttribute>]
[<SealedAttribute>]
type ObservableCepStream =  class end
public final class ObservableCepStream

Le type ObservableCepStream expose les membres suivants.

Méthodes

  Nom Description
Méthode publiqueMembre statique Select<TInput, TOutput> Projette chaque événement d'un flux d'entrée observable dans un nouvel événement.
Méthode publiqueMembre statique ToEdgeObservable<TPayload>(CepStream<TPayload>) Convertit un CepStream d'événements session en un récepteur d'événements qui implémente l'interface IObservable.L'ordre des événements est FullyOrdered.
Méthode publiqueMembre statique ToEdgeObservable<TPayload>(CepStream<TPayload>, StreamEventOrder) Convertit un CepStream d'événements session avec l'ordre des événements spécifié en un récepteur d'événements qui implémente l'interface IObservable.
Méthode publiqueMembre statique ToEdgeStream<TInput, TPayload> Convertit un flux d'entrée observable en un flux de données d'événements session et fournit les caractéristiques temporelles de l'entrée.
Méthode publiqueMembre statique ToIntervalObservable<TPayload>(CepStream<TPayload>) Convertit un CepStream d'événements intervalle en un récepteur d'événements qui implémente l'interface IObservable.L'ordre des événements est FullyOrdered.
Méthode publiqueMembre statique ToIntervalObservable<TPayload>(CepStream<TPayload>, StreamEventOrder) Convertit un CepStream d'événements intervalle avec l'ordre des événements spécifié en un récepteur d'événements qui implémente l'interface IObservable.
Méthode publiqueMembre statique ToIntervalStream<TInput, TPayload> Convertit un flux d'entrée observable en un flux de données d'événements intervalle et fournit les caractéristiques temporelles de l'entrée.
Méthode publiqueMembre statique ToObservable<TPayload>(CepStream<TPayload>) Convertit un flux de données d'événements en une sortie observable en supprimant les en-têtes d'événement et en ignorant les événements CTI.
Méthode publiqueMembre statique ToObservable<TPayload>(CepStream<TPayload>, StreamEventOrder) Convertit un flux de données d'événements en une sortie observable avec l'ordre des événements spécifié en supprimant les en-têtes d'événement et en ignorant les événements CTI.
Méthode publiqueMembre statique ToPointObservable<TPayload>(CepStream<TPayload>) Convertit un CepStream d'événements point en un récepteur d'événements qui implémente l'interface IObservable.L'ordre des événements est FullyOrdered.
Méthode publiqueMembre statique ToPointObservable<TPayload>(CepStream<TPayload>, StreamEventOrder) Convertit un CepStream d'événements point avec l'ordre des événements spécifié en un récepteur d'événements qui implémente l'interface IObservable.
Méthode publiqueMembre statique ToPointStream<TInput, TPayload> Convertit un flux d'entrée observable en un flux de données d'événements point et fournit les caractéristiques temporelles de l'entrée.
Méthode publiqueMembre statique ToStream<TPayload>(IObservable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String) Traduit la source de l'événement qui implémente l'interface IObservable en un CepStream qui peut être interrogé.
Méthode publiqueMembre statique ToStream<TPayload>(IObservable<IntervalEvent<TPayload>>, Application, AdvanceTimeSettings, String) Traduit la source de l'événement qui implémente l'interface IObservable en un CepStream qui peut être interrogé.
Méthode publiqueMembre statique ToStream<TPayload>(IObservable<PointEvent<TPayload>>, Application, AdvanceTimeSettings, String) Traduit la source de l'événement qui implémente l'interface IObservable en un CepStream qui peut être interrogé.
Méthode publiqueMembre statique Where<TInput> Filtre les événements d'un flux d'entrée observable à l'aide de l'expression de filtre spécifiée.

Haut de la page

Sécurité des threads

Tous les membres publics static (Shared dans Visual Basic) de ce type sont thread-safe. Tous les membres de l'instance ne sont pas garantis comme étant thread-safe.

Voir aussi

Référence

Espace de noms Microsoft.ComplexEventProcessing.Linq