minor: fix sync tests

Author: saghm

src/client/mod.rs

@@ -37,8 +37,10 @@ const DEFAULT_SERVER_SELECTION_TIMEOUT: Duration = Duration::from_secs(30);
 /// so it can safely be shared across threads. For example:
 ///
 /// ```rust
+/// # #[cfg(not(feature = "sync"))]
 /// # use mongodb::{Client, error::Result};
 /// #
+/// # #[cfg(not(feature = "sync"))]
 /// # async fn start_workers() -> Result<()> {
 /// let client = Client::with_uri_str("mongodb://example.com").await?;
 ///

src/coll/mod.rs

@@ -46,9 +46,12 @@ const MAX_INSERT_DOCS_BYTES: usize = 16 * 1000 * 1000;
 ///
 /// ```rust
 /// # use bson::{bson, doc};
-/// # use mongodb::{Client, error::Result};
+/// # use mongodb::error::Result;
 /// #
+/// # #[cfg(not(feature = "sync"))]
 /// # async fn start_workers() -> Result<()> {
+/// # use mongodb::Client;
+/// #
 /// # let client = Client::with_uri_str("mongodb://example.com").await?;
 /// let coll = client.database("items").collection("in_stock");
 ///

src/db/mod.rs

@@ -35,8 +35,10 @@ use crate::{
 ///
 /// ```rust
 /// 
+/// # #[cfg(not(feature = "sync"))]
 /// # use mongodb::{Client, error::Result};
-///
+/// #
+/// # #[cfg(not(feature = "sync"))]
 /// # async fn start_workers() -> Result<()> {
 /// # let client = Client::with_uri_str("mongodb://example.com").await?;
 /// let db = client.database("items");

src/event/cmap.rs

@@ -190,8 +190,11 @@ pub struct ConnectionCheckedInEvent {
 /// #         ConnectionCheckoutFailedEvent
 /// #     },
 /// #     options::ClientOptions,
-/// #     Client,
 /// # };
+/// # #[cfg(feature = "sync")]
+/// # use mongodb::sync::Client;
+/// # #[cfg(not(feature = "sync"))]
+/// # use mongodb::Client;
 /// #
 /// struct FailedCheckoutLogger;
 ///

src/event/command.rs

@@ -84,8 +84,11 @@ pub struct CommandFailedEvent {
 /// #         CommandFailedEvent
 /// #     },
 /// #     options::ClientOptions,
-/// #     Client,
 /// # };
+/// # #[cfg(feature = "sync")]
+/// # use mongodb::sync::Client;
+/// # #[cfg(not(feature = "sync"))]
+/// # use mongodb::Client;
 /// #
 /// struct FailedCommandLogger;
 ///

src/lib.rs

@@ -5,8 +5,10 @@
 //! [`Client::with_uri_str`](struct.Client.html#method.with_uri_str):
 //!
 //! ```rust
+//! # #[cfg(not(feature = "sync"))]
 //! # use mongodb::{Client, error::Result};
 //! #
+//! # #[cfg(not(feature = "sync"))]
 //! # async fn make_client() -> Result<Client> {
 //! let client = Client::with_uri_str("mongodb://localhost:27017/").await?;
 //! # Ok(client)
@@ -19,8 +21,11 @@
 //! # use mongodb::{
 //! #     error::Result,
 //! #     options::{StreamAddress, ClientOptions},
-//! #     Client,
 //! # };
+//! # #[cfg(feature = "sync")]
+//! # use mongodb::sync::Client;
+//! # #[cfg(not(feature = "sync"))]
+//! # use mongodb::Client;
 //! #
 //! # fn make_client() -> Result<Client> {
 //! let options = ClientOptions::builder()
@@ -42,10 +47,13 @@
 //!
 //! ```rust
 //! # use bson::{bson, doc};
-//! # use mongodb::{Client, error::Result};
+//! # use mongodb::error::Result;
+//! # #[cfg(not(feature = "sync"))]
+//! # use mongodb::Client;
 //! #
+//! # #[cfg(not(feature = "sync"))]
 //! # async fn do_stuff() -> Result<()> {
-//! # let client = Client::with_uri_str("mongodb://localhost:27017").await?;
+//! # let client = Client::with_uri_str("mongodb://example.com").await?;
 //! #
 //! let db = client.database("some_db");
 //! for coll_name in db.list_collection_names(None).await? {
@@ -133,16 +141,20 @@ define_if_single_runtime_enabled! {
     pub use coll::Namespace;
 }
 
-#[cfg(all(feature = "tokio-runtime", feature = "async-std-runtime", not(feature = "sync")))]
+#[cfg(all(
+    feature = "tokio-runtime",
+    feature = "async-std-runtime",
+    not(feature = "sync")
+))]
 compile_error!(
     "`tokio-runtime` and `async-runtime` can't both be enabled; either disable \
      `async-std-runtime` or set `default-features = false` in your Cargo.toml"
 );
 
 #[cfg(all(feature = "tokio-runtime", feature = "sync"))]
 compile_error!(
-    "`tokio-runtime` and `sync` can't both be enabled; either disable \
-     `sync` or set `default-features = false` in your Cargo.toml"
+    "`tokio-runtime` and `sync` can't both be enabled; either disable `sync` or set \
+     `default-features = false` in your Cargo.toml"
 );
 
 #[cfg(all(not(feature = "tokio-runtime"), not(feature = "async-std-runtime")))]

src/sync/cursor.rs

@@ -1,12 +1,7 @@
 use bson::Document;
 use futures::StreamExt;
 
-use crate::{
-    cursor::ImpatientCursor as AsyncImpatientCursor,
-    error::Result,
-    Cursor as AsyncCursor,
-    RUNTIME,
-};
+use crate::{error::Result, Cursor as AsyncCursor, RUNTIME};
 
 /// A `Cursor` streams the result of a query. When a query is made, a `Cursor` will be returned with
 /// the first batch of results from the server; the documents will be returned as the `Cursor` is
@@ -71,10 +66,6 @@ impl Cursor {
     pub(crate) fn new(async_cursor: AsyncCursor) -> Self {
         Self { async_cursor }
     }
-
-    pub fn into_impatient(self) -> ImpatientCursor {
-        ImpatientCursor::new(self.async_cursor.into_impatent())
-    }
 }
 
 impl Iterator for Cursor {
@@ -84,22 +75,3 @@ impl Iterator for Cursor {
         RUNTIME.block_on(self.async_cursor.next())
     }
 }
-
-#[derive(Debug)]
-pub struct ImpatientCursor {
-    async_cursor: AsyncImpatientCursor,
-}
-
-impl ImpatientCursor {
-    pub(crate) fn new(async_cursor: AsyncImpatientCursor) -> Self {
-        Self { async_cursor }
-    }
-}
-
-impl Iterator for ImpatientCursor {
-    type Item = Result<Document>;
-
-    fn next(&mut self) -> Option<Self::Item> {
-        RUNTIME.block_on(self.async_cursor.next())
-    }
-}