createStream<T extends Object> method

Stream<T> createStream<T extends Object>(
  1. QueryStreamFetcher<T> stmt
)
inherited

Creates and auto-updating stream from the given select statement. This method should not be used directly.

Implementation

Stream<T> createStream<T extends Object>(QueryStreamFetcher<T> stmt) =>
    resolvedEngine.streamQueries.registerStream(stmt, this);