or run

npx @tessl/cli init
Log in

Version

Tile

Overview

Evals

Files

Files

docs

aggregation.mdauthentication-security.mdbson-types.mdchange-streams.mdcollection-operations.mdconfiguration.mdconnection-management.mddatabase-operations.mdgridfs.mdindex.mdquery-building.mdsessions-transactions.md

change-streams.mddocs/

0

# Change Streams

1

2

Real-time data monitoring with resumable change streams for tracking database, collection, and document-level changes with full event details.

3

4

## Capabilities

5

6

### ChangeStreamIterable Interface

7

8

```java { .api }

9

public interface ChangeStreamIterable<TResult> extends MongoIterable<ChangeStreamDocument<TResult>> {

10

ChangeStreamIterable<TResult> fullDocument(FullDocument fullDocument);

11

ChangeStreamIterable<TResult> resumeAfter(BsonDocument resumeToken);

12

ChangeStreamIterable<TResult> startAfter(BsonDocument startAfter);

13

ChangeStreamIterable<TResult> startAtOperationTime(BsonTimestamp startAtOperationTime);

14

ChangeStreamIterable<TResult> maxAwaitTime(long maxAwaitTime, TimeUnit timeUnit);

15

ChangeStreamIterable<TResult> batchSize(int batchSize);

16

}

17

18

public class ChangeStreamDocument<TDocument> {

19

public OperationType getOperationType();

20

public BsonDocument getResumeToken();

21

public MongoNamespace getNamespace();

22

public BsonDocument getDocumentKey();

23

public TDocument getFullDocument();

24

}

25

```

26

27

*[Full change streams documentation would follow...]*