Compartilhar via

Suporte à API para IObservable e IEnumerable no StreamInsight

  • Artigo

Este tópico resume os recursos da API no StreamInsight que oferece suporte a origens e coletores de eventos que implementam as interfaces IObservable ou IEnumerable.

Suporte da API para entradas observáveis e enumeráveis

Os recursos da API a seguir dão suporte a origens de eventos que implementam as interfaces IObservable ou IEnumerable.

Criando entradas

Criando entradas associadas

Crie um fluxo de entrada que esteja associado a um aplicativo usando uma das seguintes cargas para o método Create da classe CepStream<(Of <(<'TPayload>)>)>.

Criando entradas de uma entrada observável

Traduza uma origem de evento IObservable em um fluxo de entrada usando uma das seguintes cargas para o método ToStream da classe ObservableCepStream.

Criando entradas de uma entrada enumerável

Traduza uma origem de evento IEnumerable em um fluxo de entrada usando uma das seguintes cargas para o método ToStream da classe CepStream.

Descrevendo as características temporais

Descreva as características temporais dos dados de origem usando um dos seguintes auxiliares na classe AdvanceTimeSettings.

Mapeando entrada para eventos pontuais, de intervalo e de borda.

Mapeie dados de entrada para eventos pontuais, de intervalo e de borda usando os seguintes métodos em uma expressão passada para uma carga do método ToStream.

Mapeando entrada para eventos pontuais

Mapeie dados de entrada para eventos pontuais e os eventos CTI correspondentes usando os seguintes métodos da classe PointEvent ou PointEvent<(Of <(<'TPayload>)>)> em uma expressão passada para uma carga do método ToStream.

Mapeando entrada para eventos de intervalo

Mapeie dados de entrada para eventos de intervalo e os eventos CTI correspondentes usando os seguintes métodos da classe IntervalEvent ou IntervalEvent<(Of <(<'TPayload>)>)> em uma expressão passada para uma carga do método ToStream.

Criando eventos de borda

Mapeie dados de entrada para eventos de borda e os eventos CTI correspondentes usando os seguintes métodos da classe EdgeEvent ou EdgeEvent<(Of <(<'TPayload>)>)> em uma expressão passada para uma carga do método ToStream.

Suporte da API para saídas observáveis e enumeráveis

Os recursos da API a seguir dão suporte a coletores de eventos que implementam as interfaces IObservable ou IEnumerable.

Criando saídas

Traduza um fluxo de eventos em uma saída IObservable para uma forma de evento específico usando um dos seguintes métodos da classe ObservableCepStream.

Traduza um fluxo de eventos em uma saída IEnumerable para uma forma de evento específico usando um dos seguintes métodos da classe CepStream.

Mapeando a saída

Mapeando a saída observável

Use os seguintes métodos do ObservableCepStream para mapear a saída observável.

Mapeando a saída enumerável

Use os seguintes métodos do CepStream para mapear a saída enumerável.

Interfaces estendidas para coletores de eventos

Os métodos descritos acima para criar e filtrar a saída retornam coletores de eventos que implementam interfaces que estendem as interfaces de base IObservable e IEnumerable. Especificamente, as interfaces estendidas permitem fornecer um nome de consulta para fins de depuração