Stream | beneath

Type parameters

TRecord = any

Hierarchy

Stream

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new Stream<TRecord>(connection: Connection, streamQualifier: StreamQualifier): Stream<TRecord>

- Defined in Stream.ts:15
Type parameters
- TRecord = any
Parameters
- connection: Connection
- streamQualifier: StreamQualifier
Returns Stream<TRecord>

Properties

Private connection

connection: Connection

Private streamQualifier

streamQualifier: StreamQualifier

Methods

queryIndex

queryIndex(opts?: QueryIndexOptions): Promise<QueryResult<TRecord>>

- Defined in Stream.ts:47
Parameters
- Optional opts: QueryIndexOptions
Returns Promise<QueryResult<TRecord>>

queryLog

queryLog(opts?: QueryLogOptions): Promise<QueryResult<TRecord>>

- Defined in Stream.ts:31
Parameters
- Optional opts: QueryLogOptions
Returns Promise<QueryResult<TRecord>>

write

write(records: TRecord[]): Promise<WriteResult>

- Defined in Stream.ts:22
Parameters
- records: TRecord[]
Returns Promise<WriteResult>

Generated using TypeDoc