mongochangestream
Advanced tools
Comparing version 0.27.0 to 0.28.0
@@ -0,1 +1,5 @@ | ||
# 0.28.0 | ||
- Don't type event emitter so that it can be reused by downstream libraries like `mongo2crate` and `mongo2elastic`. | ||
# 0.27.0 | ||
@@ -2,0 +6,0 @@ |
import _ from 'lodash/fp.js'; | ||
import { Collection, ObjectId, Db } from 'mongodb'; | ||
import { Events, SyncOptions, ProcessRecord, ProcessRecords, ScanOptions, ChangeOptions, ChangeStreamOptions, JSONSchema } from './types.js'; | ||
import { SyncOptions, ProcessRecord, ProcessRecords, ScanOptions, ChangeOptions, ChangeStreamOptions, JSONSchema } from './types.js'; | ||
import type { Redis } from 'ioredis'; | ||
@@ -70,3 +70,3 @@ import { QueueOptions } from 'prom-utils'; | ||
/** Event emitter */ | ||
emitter: EventEmitter<Events, any>; | ||
emitter: EventEmitter<string | symbol, any>; | ||
}; |
{ | ||
"name": "mongochangestream", | ||
"version": "0.27.0", | ||
"version": "0.28.0", | ||
"description": "Sync MongoDB collections via change streams into any database.", | ||
@@ -5,0 +5,0 @@ "author": "GovSpend", |
@@ -74,3 +74,3 @@ import _ from 'lodash/fp.js' | ||
const omitPipeline = omit ? generatePipelineFromOmit(omit) : [] | ||
const emitter = new EventEmitter<Events>() | ||
const emitter = new EventEmitter() | ||
const emit = (event: Events, data: object) => { | ||
@@ -77,0 +77,0 @@ emitter.emit(event, { type: event, ...data }) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
54081