Skip to content

Commit d7e505a

Browse files
authored
refactor: merge CoreCursor into Cursor
NODE-2839
1 parent a54be7a commit d7e505a

17 files changed

+882
-991
lines changed

src/change_stream.ts

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import Denque = require('denque');
22
import { EventEmitter } from 'events';
33
import { MongoError, AnyError, isResumableError } from './error';
4-
import { Cursor, CursorOptions, CursorStream } from './cursor/cursor';
4+
import { Cursor, CursorOptions, CursorStream, CursorStreamOptions } from './cursor/cursor';
55
import { AggregateOperation, AggregateOptions } from './operations/aggregate';
66
import { loadCollection, loadDb, loadMongoClient } from './dynamic_loaders';
77
import {
@@ -18,7 +18,6 @@ import type { Timestamp, Document } from './bson';
1818
import type { Topology } from './sdam/topology';
1919
import type { OperationParent } from './operations/command';
2020
import type { CollationOptions } from './cmap/wire_protocol/write_command';
21-
import type { CursorStreamOptions } from './cursor/core_cursor';
2221
const kResumeQueue = Symbol('resumeQueue');
2322
const kCursorStream = Symbol('cursorStream');
2423

src/cursor/aggregation_cursor.ts

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
import { MongoError } from '../error';
2-
import { Cursor, CursorOptions } from './cursor';
3-
import { CursorState } from './core_cursor';
2+
import { Cursor, CursorOptions, CursorState } from './cursor';
43
import type { AggregateOperation, AggregateOptions } from '../operations/aggregate';
54
import type { Document } from '../bson';
65
import type { Sort } from '../operations/find';

src/cursor/command_cursor.ts

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
import { ReadPreference, ReadPreferenceLike } from '../read_preference';
22
import { MongoError } from '../error';
3-
import { Cursor, CursorOptions } from './cursor';
4-
import { CursorState } from './core_cursor';
3+
import { Cursor, CursorOptions, CursorState } from './cursor';
54
import type { Topology } from '../sdam/topology';
65
import type { CommandOperation } from '../operations/command';
76

0 commit comments

Comments
 (0)