Class QueryObserver

StreamObserver handles the stream of data coming from the server. It stores the result until the subscription is established

Implements

  • ResponseHandlerObserver

Constructors

constructor

Properties

_error _pendingRecords _queryPreamble _resultObserver _summary _variableToIndex _variables

Methods

onError onRecord onSuccess onVariables subscribe unsubscribe

Constructors

constructor

Properties

Private _error

_error: null | MillenniumDBError

Private Readonly _pendingRecords

_pendingRecords: Record[]

Private _queryPreamble

_queryPreamble: null | QueryPreamble

Private _resultObserver

_resultObserver: null | ResultObserver

Private _summary

_summary: any

Private _variableToIndex

_variableToIndex: {
    [key: string]: number;
}

Type declaration

  • [key: string]: number

Private _variables

_variables: string[]

Methods

onError

onRecord

  • onRecord(values): void

  • Parameters

    • values: any[]

    Returns void

onSuccess

  • onSuccess(summary): void

  • Parameters

    • summary: any

    Returns void

onVariables

  • onVariables(variables, queryPreamble): void

  • Parameters

    • variables: string[]
    • queryPreamble: QueryPreamble

    Returns void

subscribe

unsubscribe

Settings

Member Visibility

Theme

On This Page

constructor_error_pendingRecords_queryPreamble_resultObserver_summary_variableToIndex_variablesonErroronRecordonSuccessonVariablessubscribeunsubscribe