Skip to content

Commit 8460781

Browse files
rebase fixes
1 parent f9c5997 commit 8460781

File tree

4 files changed

+2
-17
lines changed

4 files changed

+2
-17
lines changed

src/action/bulk_write.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ impl<'a> BulkWrite<'a> {
118118
}
119119

120120
action_impl! {
121-
impl Action<'a> for BulkWrite<'a> {
121+
impl<'a> Action for BulkWrite<'a> {
122122
type Future = BulkWriteFuture;
123123

124124
async fn execute(mut self) -> Result<BulkWriteResult> {

src/error.rs

+1-7
Original file line numberDiff line numberDiff line change
@@ -7,18 +7,12 @@ use std::{
77
sync::Arc,
88
};
99

10-
use crate::{
11-
bson::Document,
12-
options::ServerAddress,
13-
sdam::{ServerType, TopologyVersion},
14-
};
15-
use bson::Bson;
1610
use serde::{Deserialize, Serialize};
1711
use thiserror::Error;
1812

1913
use crate::{
2014
action::bulk_write::error::BulkWriteError as ClientBulkWriteError,
21-
bson::Document,
15+
bson::{Bson, Document},
2216
options::ServerAddress,
2317
sdam::{ServerType, TopologyVersion},
2418
};

src/operation.rs

-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,6 @@ use crate::{
5252
};
5353

5454
pub(crate) use abort_transaction::AbortTransaction;
55-
pub(crate) use bulk_write::{BulkWrite, BulkWriteOperationResponse, BulkWriteSummaryInfo};
5655
pub(crate) use commit_transaction::CommitTransaction;
5756
pub(crate) use create_indexes::CreateIndexes;
5857
pub(crate) use delete::Delete;

src/selection_criteria.rs

-8
Original file line numberDiff line numberDiff line change
@@ -53,14 +53,6 @@ impl SelectionCriteria {
5353
}
5454
}
5555

56-
#[cfg(test)]
57-
pub(crate) fn as_predicate(&self) -> Option<&Predicate> {
58-
match self {
59-
Self::Predicate(ref p) => Some(p),
60-
_ => None,
61-
}
62-
}
63-
6456
pub(crate) fn from_address(address: ServerAddress) -> Self {
6557
SelectionCriteria::Predicate(Arc::new(move |server| server.address() == &address))
6658
}

0 commit comments

Comments
 (0)