Home Reference Source
import RxResult from 'neo4j-driver/lib/result-rx.js'
public class | source

RxResult

Method Summary

Public Methods
public

consume(): Observable<ResultSummary>

Returns an observable that exposes a single item of ResultSummary that is generated by the server after the streaming of the executing query is completed.

public

keys(): Observable<string[]>

Returns an observable that exposes a single item containing field names returned by the executing query.

public

records(): Observable<Record>

Returns an observable that exposes each record returned by the executing query.

Public Methods

public consume(): Observable<ResultSummary> source

Returns an observable that exposes a single item of ResultSummary that is generated by the server after the streaming of the executing query is completed.

Subscribing to this stream before subscribing to records() stream causes the results to be discarded on the server.

Return:

Observable<ResultSummary>

An observable stream (with exactly one element) of result summary.

public keys(): Observable<string[]> source

Returns an observable that exposes a single item containing field names returned by the executing query.

Errors raised by actual query execution can surface on the returned observable stream.

Return:

Observable<string[]>

An observable stream (with exactly one element) of field names.

public records(): Observable<Record> source

Returns an observable that exposes each record returned by the executing query.

Errors raised during the streaming phase can surface on the returned observable stream.

Return:

Observable<Record>

An observable stream of records.