import * as neo4jLiteClient from "https://deno.land/x/neo4j_lite_client@4.4.6/bolt-connection/bolt/stream-observers.js";
Classes
Handles a RUN/PULL_ALL, or RUN/DISCARD_ALL requests, maps the responses in a way that a user-provided observer can see these as a clean Stream of records. This class will queue up incoming messages until a user-provided observer for the incoming stream is registered. Thus, we keep fields around for tracking head/records/tail. These are only used if there is no observer registered. | |