How to use the @graffy/common.addQueries function in @graffy/common

To help you get started, we’ve selected a few @graffy/common examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github usegraffy / graffy / src / cache / Cache.js View on Github external
getStream(query) {
    const id = this.lastListenerId++;
    const [push, stream] = makeStream(() => {
      delete this.listeners[id];
      this.sumQuery = subtractQueries(this.sumQuery, query);
      // console.log(this.id, 'Ended stream', id, query, this.sumQuery);
      // console.log(this.id, 'Resubscribe due to stream close');
      return this.resubscribe();
    });

    this.listeners[id] = {
      originalQuery: query,
      query: linkKnown(this.data, query),
      push,
    };
    this.sumQuery = addQueries(this.sumQuery, query);
    // console.log(this.id, 'Started stream', id, query, this.sumQuery);
    // console.log(this.id, 'Resubscribe due to query start');
    this.resubscribe();
    return stream;
  }
github usegraffy / graffy / src / cache / Cache.js View on Github external
raw: true,
        });
      } catch (e) {
        console.error('Error getting fillData for', gaps);
        console.error(e);
      }
      if (fillData) {
        merge(this.data, fillData);
        merge(value, fillData);
      }
    }

    for (const id in this.listeners) {
      const { lastQuery = {}, originalQuery, push } = this.listeners[id];
      const nextQuery = linkKnown(this.data, originalQuery);
      const query = addQueries(lastQuery, nextQuery);
      this.listeners[id].lastQuery = nextQuery;

      const payload = getKnown(value, query);
      if (payload) push(payload);
    }
  }
}