@naturalcycles/db-lib - npm Package Compare versions

Comparing version 9.3.1 to 9.3.2

dist/commondao/common.dao.d.ts

		@@ -63,7 +63,7 @@ /// <reference types="node" />
		streamQueryForEach(q: DBQuery<DBM>, mapper: AsyncMapper<Saved<BM>, void>, opt?: CommonDaoStreamForEachOptions<Saved<BM>>): Promise<void>;
		streamQueryAsDBMForEach(q: DBQuery<DBM>, mapper: AsyncMapper<DBM, void>, opt?: CommonDaoStreamForEachOptions<DBM>): Promise<void>;
		streamQueryAsDBMForEach(q: DBQuery<DBM>, mapper: AsyncMapper<Saved<DBM>, void>, opt?: CommonDaoStreamForEachOptions<DBM>): Promise<void>;
		/**
		* Stream as Readable, to be able to .pipe() it further with support of backpressure.
		*/
		streamQueryAsDBM(q: DBQuery<DBM>, opt?: CommonDaoStreamOptions<DBM>): ReadableTyped<DBM>;
		streamQueryAsDBM(q: DBQuery<DBM>, opt?: CommonDaoStreamOptions<DBM>): ReadableTyped<Saved<DBM>>;
		/**
		@@ -70,0 +70,0 @@ * Stream as Readable, to be able to .pipe() it further with support of backpressure.

dist/query/dbQuery.d.ts

		@@ -103,5 +103,5 @@ import { AsyncMapper, Saved, AnyObject, PartialObjectWithId, AnyPartialObjectWithId } from '@naturalcycles/js-lib';
		streamQueryForEach(mapper: AsyncMapper<Saved<BM>, void>, opt?: CommonDaoStreamForEachOptions<Saved<BM>>): Promise<void>;
		streamQueryAsDBMForEach(mapper: AsyncMapper<DBM, void>, opt?: CommonDaoStreamForEachOptions<DBM>): Promise<void>;
		streamQueryAsDBMForEach(mapper: AsyncMapper<Saved<DBM>, void>, opt?: CommonDaoStreamForEachOptions<DBM>): Promise<void>;
		streamQuery(opt?: CommonDaoStreamOptions<Saved<BM>>): ReadableTyped<Saved<BM>>;
		streamQueryAsDBM(opt?: CommonDaoStreamOptions<DBM>): ReadableTyped<DBM>;
		streamQueryAsDBM(opt?: CommonDaoStreamOptions<DBM>): ReadableTyped<Saved<DBM>>;
		queryIds(opt?: CommonDaoOptions): Promise<string[]>;
		@@ -108,0 +108,0 @@ streamQueryIds(opt?: CommonDaoStreamOptions<string>): ReadableTyped<string>;

package.json

		@@ -43,3 +43,3 @@ {
		},
		"version": "9.3.1",
		"version": "9.3.2",
		"description": "Lowest Common Denominator API to supported Databases",
		@@ -46,0 +46,0 @@ "keywords": [

src/commondao/common.dao.ts

		@@ -487,3 +487,3 @@ import { Transform } from 'node:stream'
		q: DBQuery<DBM>,
		mapper: AsyncMapper<DBM, void>,
		mapper: AsyncMapper<Saved<DBM>, void>,
		opt: CommonDaoStreamForEachOptions<DBM> = {},
		@@ -519,3 +519,3 @@ ): Promise<void> {
		),
		transformMap<DBM, void>(mapper, {
		transformMap<Saved<DBM>, void>(mapper, {
		...opt,
		@@ -540,3 +540,6 @@ predicate: _passthroughPredicate, // to be able to logProgress
		*/
		streamQueryAsDBM(q: DBQuery<DBM>, opt: CommonDaoStreamOptions<DBM> = {}): ReadableTyped<DBM> {
		streamQueryAsDBM(
		q: DBQuery<DBM>,
		opt: CommonDaoStreamOptions<DBM> = {},
		): ReadableTyped<Saved<DBM>> {
		q.table = opt.table \|\| q.table
		@@ -543,0 +546,0 @@ opt.skipValidation = opt.skipValidation !== false // default true

src/query/dbQuery.ts

		@@ -300,3 +300,3 @@ import {
		async streamQueryAsDBMForEach(
		mapper: AsyncMapper<DBM, void>,
		mapper: AsyncMapper<Saved<DBM>, void>,
		opt?: CommonDaoStreamForEachOptions<DBM>,
		@@ -311,3 +311,3 @@ ): Promise<void> {

		streamQueryAsDBM(opt?: CommonDaoStreamOptions<DBM>): ReadableTyped<DBM> {
		streamQueryAsDBM(opt?: CommonDaoStreamOptions<DBM>): ReadableTyped<Saved<DBM>> {
		return this.dao.streamQueryAsDBM(this, opt)
		@@ -314,0 +314,0 @@ }

New alerts