We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f258c21 commit 0f0d84aCopy full SHA for 0f0d84a
src/operation/bulk_write.rs
@@ -6,7 +6,7 @@ use futures_core::TryStream;
6
use futures_util::{FutureExt, TryStreamExt};
7
8
use crate::{
9
- bson::{doc, rawdoc, Bson, RawDocumentBuf},
+ bson::{rawdoc, Bson, RawDocumentBuf},
10
bson_util::{self, extend_raw_document_buf},
11
checked::Checked,
12
cmap::{Command, RawCommandResponse, StreamDescription},
@@ -121,12 +121,12 @@ where
121
Ok(response) => response,
122
Err(error) => {
123
if !error.is_network_error() {
124
- let kill_cursors = doc! {
125
- "killCursors": &namespace.db,
+ let kill_cursors = rawdoc! {
+ "killCursors": namespace.db.clone(),
126
"cursors": [cursor_specification.info.id],
127
};
128
let mut run_command =
129
- RunCommand::new(namespace.db.clone(), kill_cursors, None, None)?;
+ RunCommand::new(namespace.db.clone(), kill_cursors, None, None);
130
let _ = self
131
.client
132
.execute_operation_on_connection(
0 commit comments