Skip to content

Commit 71d7bfc

Browse files
committed
mysql-srv: Remove dead function run_on_stream()
I think this function was used a long time ago, but it's not referenced anywhere any longer. Yank it. Change-Id: I7ed7c2758e4757f4bd1c25b123e12571a81dd20b Reviewed-on: https://gerrit.readyset.name/c/readyset/+/10702 Tested-by: Buildkite CI Reviewed-by: Marcelo Altmann <marcelo@readyset.io>
1 parent 3c793ff commit 71d7bfc

File tree

1 file changed

+0
-21
lines changed

1 file changed

+0
-21
lines changed

mysql-srv/src/lib.rs

Lines changed: 0 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -431,27 +431,6 @@ impl<B: MySqlShim<net::TcpStream> + Send> MySqlIntermediary<B, net::TcpStream> {
431431
}
432432
}
433433

434-
impl<B: MySqlShim<S> + Send, S: AsyncRead + AsyncWrite + Unpin + Send> MySqlIntermediary<B, S> {
435-
/// Create a new server over a stream and process client commands until the client
436-
/// disconnects or an error occurs. See also [`MySqlIntermediary::run_on`].
437-
pub async fn run_on_stream(
438-
shim: B,
439-
stream: S,
440-
enable_statement_logging: bool,
441-
tls_acceptor: Option<Arc<TlsAcceptor>>,
442-
tls_mode: TlsMode,
443-
) -> Result<(), io::Error> {
444-
MySqlIntermediary::run_on(
445-
shim,
446-
stream,
447-
enable_statement_logging,
448-
tls_acceptor,
449-
tls_mode,
450-
)
451-
.await
452-
}
453-
}
454-
455434
/// Send an error packet to the given stream, then close it
456435
pub async fn send_immediate_err<S>(stream: S, error_kind: ErrorKind, msg: &[u8]) -> io::Result<()>
457436
where

0 commit comments

Comments
 (0)