Remove try_flush

Signed-off-by: Tomasz Pietrek <[email protected]>
nats-io · Aug 5, 2023 · 01282bf · 01282bf
1 parent e295c94
commit 01282bf
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs
@@ -18,7 +18,7 @@ use crate::header::{IntoHeaderName, IntoHeaderValue};
 use crate::jetstream::account::Account;
 use crate::jetstream::publish::PublishAck;
 use crate::jetstream::response::Response;
-use crate::{header, Client, Command, HeaderMap, HeaderValue, StatusCode};
+use crate::{header, Client, HeaderMap, HeaderValue, StatusCode};
 use bytes::Bytes;
 use futures::future::BoxFuture;
 use futures::{Future, StreamExt, TryFutureExt};

diff --git a/async-nats/src/lib.rs b/async-nats/src/lib.rs
@@ -282,7 +282,6 @@ pub(crate) enum Command {
     Flush {
         result: oneshot::Sender<Result<(), io::Error>>,
     },
-    TryFlush,
 }
 
 /// `ClientOp` represents all actions of `Client`.
@@ -566,9 +565,6 @@ impl ConnectionHandler {
                     })?;
                 }
             }
-            Command::TryFlush => {
-                self.handle_flush().await?;
-            }
             Command::Subscribe {
                 sid,
                 subject,