resumeToken
ResumeToken
The cached resume token that will be used to resume
after the most recently returned change.
Close the Change Stream
Check if there is any document still available in the Change Stream
Is the change stream closed
Get the next available document from the Change Stream, returns null if no more documents are available.
This method will cause a stream in flowing mode to stop emitting data events. Any data that becomes available will remain in the internal buffer.
This method pulls all the data out of a readable stream, and writes it to the supplied destination, automatically managing the flow so that the destination is not overwhelmed by a fast readable stream.
Name Type Descriptiondestination
Writable
The destination for writing data
options
object optional
This method will cause the readable stream to resume emitting data events.
Return a modified Readable stream including a possible transform method.
Name Type Descriptionoptions
object optional
Optional settings.
Name Type Descriptiontransform
function optional
A transformation method applied to each document emitted by the stream.
This method will remove the hooks set up for a previous pipe() call.
Name Type Descriptiondestination
Writable optional
The destination for writing data
The callback format for results
Name Type Descriptionerror
MongoError
An error instance representing the error during the execution.
result
object | null
The result object if the command was executed successfully.
Fired for each new matching change in the specified namespace. Attaching a change
event listener to a Change Stream will switch the stream into flowing mode. Data will
then be passed as soon as it is available.
Change stream close event
Type:Change stream end event
Type:Fired when the stream encounters an error.
Type:Emitted each time the change stream stores a new resume token.
Type:RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4