Struct QueryResultStream 

pub struct QueryResultStream { /* private fields */ }

Streaming query result iterator

Implementations

impl QueryResultStream

pub fn instance_of<V: NapiRaw>(env: Env, value: V) -> Result<bool>

impl QueryResultStream

pub fn into_reference( val: QueryResultStream, env: Env, ) -> Result<Reference<QueryResultStream>>

pub fn into_instance(self, env: Env) -> Result<ClassInstance<QueryResultStream>>

impl QueryResultStream

pub fn new(stream: Pin<Box<dyn Stream<Item = JsQueryResult> + Send>>) -> Self

Create a new query result stream

impl QueryResultStream

pub fn next(&mut self) -> Result<Option<JsQueryResult>>

Get the next result from the stream

Example

const stream = await db.queryStream('MATCH (n) RETURN n');
while (true) {
  const result = await stream.next();
  if (!result) break;
  console.log(result);
}

Trait Implementations

impl FromNapiMutRef for QueryResultStream

unsafe fn from_napi_mut_ref( env: napi_env, napi_val: napi_value, ) -> Result<&'static mut Self>

Safety

impl FromNapiRef for QueryResultStream

unsafe fn from_napi_ref( env: napi_env, napi_val: napi_value, ) -> Result<&'static Self>

Safety

impl FromNapiValue for &QueryResultStream

unsafe fn from_napi_value(env: napi_env, napi_val: napi_value) -> Result<Self>

Safety

fn from_unknown(value: JsUnknown) -> Result<Self, Error>

impl FromNapiValue for &mut QueryResultStream

unsafe fn from_napi_value(env: napi_env, napi_val: napi_value) -> Result<Self>

Safety

fn from_unknown(value: JsUnknown) -> Result<Self, Error>

impl ObjectFinalize for QueryResultStream

fn finalize(self, env: Env) -> Result<(), Error>

impl ToNapiValue for QueryResultStream

unsafe fn to_napi_value( env: napi_env, val: QueryResultStream, ) -> Result<napi_value>

Safety

impl TypeName for &QueryResultStream

fn type_name() -> &'static str

fn value_type() -> ValueType

impl TypeName for &mut QueryResultStream

fn type_name() -> &'static str

fn value_type() -> ValueType

impl TypeName for QueryResultStream

fn type_name() -> &'static str

fn value_type() -> ValueType

impl ValidateNapiValue for &QueryResultStream

unsafe fn validate(env: napi_env, napi_val: napi_value) -> Result<napi_value>

Safety

impl ValidateNapiValue for &mut QueryResultStream

unsafe fn validate(env: napi_env, napi_val: napi_value) -> Result<napi_value>

Safety