eUgEntOptIc44/gitoxide
1
1
Fork 0
mirror of https://github.com/Byron/gitoxide synced 2025-10-06 01:52:40 +02:00
Code Issues Activity

a few more missing semicolons

Browse Source
This commit is contained in:
Yuri Astrakhan
2024-08-24 10:22:24 -04:00
parent 7b6e1764dc
commit fc45c931c1
8 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gix-features/tests/hash.rs
View File

@@ -3,7 +3,7 @@ use gix_features::hash::Sha1;
#[cfg(not(feature = "fast-sha1"))]
#[test]
fn size_of_sha1() {
assert_eq!(std::mem::size_of::<Sha1>(), 96)
assert_eq!(std::mem::size_of::<Sha1>(), 96);
}
#[cfg(feature = "fast-sha1")]

10
gix-packetline/src/encode/async_io.rs
View File

@@ -70,7 +70,7 @@ impl<W: AsyncWrite + Unpin> AsyncWrite for LineWriter<'_, W> {
}
let data_len = data_len + 4;
let len_buf = u16_to_hex(data_len as u16);
*this.state = State::WriteHexLen(len_buf, 0)
*this.state = State::WriteHexLen(len_buf, 0);
}
State::WriteHexLen(hex_len, written) => {
while *written != hex_len.len() {
@@ -81,9 +81,9 @@ impl<W: AsyncWrite + Unpin> AsyncWrite for LineWriter<'_, W> {
*written += n;
}
if this.prefix.is_empty() {
*this.state = State::WriteData(0)
*this.state = State::WriteData(0);
} else {
*this.state = State::WritePrefix(this.prefix)
*this.state = State::WritePrefix(this.prefix);
}
}
State::WritePrefix(buf) => {
@@ -95,7 +95,7 @@ impl<W: AsyncWrite + Unpin> AsyncWrite for LineWriter<'_, W> {
let (_, rest) = std::mem::take(buf).split_at(n);
*buf = rest;
}
*this.state = State::WriteData(0)
*this.state = State::WriteData(0);
}
State::WriteData(written) => {
while *written != data.len() {
@@ -110,7 +110,7 @@ impl<W: AsyncWrite + Unpin> AsyncWrite for LineWriter<'_, W> {
*this.state = State::Idle;
return Poll::Ready(Ok(written));
} else {
*this.state = State::WriteSuffix(this.suffix)
*this.state = State::WriteSuffix(this.suffix);
}
}
State::WriteSuffix(buf) => {

2
gix-packetline/src/read/sidebands/async_io.rs
View File

@@ -106,7 +106,7 @@ where
parent
.as_mut()
.expect("parent is always available if we are idle")
.reset_with(delimiters)
.reset_with(delimiters);
}
}

2
gix-packetline/src/write/async_io.rs
View File

@@ -68,7 +68,7 @@ impl<T: AsyncWrite + Unpin> AsyncWrite for Writer<T> {
"empty packet lines are not permitted as '0004' is invalid",
)));
}
*this.state = State::WriteData(0)
*this.state = State::WriteData(0);
}
State::WriteData(written) => {
while *written != buf.len() {

2
gix-packetline/tests/read/sideband.rs
View File

@@ -30,7 +30,7 @@ mod util {
}
fn consume(&mut self, amt: usize) {
Pin::new(&mut self.0).consume(amt)
Pin::new(&mut self.0).consume(amt);
}
}
}

2
gix-protocol/src/handshake/refs/tests.rs
View File

@@ -226,7 +226,7 @@ impl<'a> futures_io::AsyncBufRead for Fixture<'a> {
}
fn consume(self: std::pin::Pin<&mut Self>, amt: usize) {
self.project_inner().consume(amt)
self.project_inner().consume(amt);
}
}

6
gix-transport/src/client/async_io/bufread_ext.rs
View File

@@ -72,7 +72,7 @@ impl<'a, T: ReadlineBufRead + ?Sized + 'a + Unpin> ReadlineBufRead for Box<T> {
#[async_trait(?Send)]
impl<'a, T: ExtendedBufRead<'a> + ?Sized + 'a + Unpin> ExtendedBufRead<'a> for Box<T> {
fn set_progress_handler(&mut self, handle_progress: Option<HandleProgress<'a>>) {
self.deref_mut().set_progress_handler(handle_progress)
self.deref_mut().set_progress_handler(handle_progress);
}
async fn peek_data_line(&mut self) -> Option<io::Result<Result<&[u8], Error>>> {
@@ -80,7 +80,7 @@ impl<'a, T: ExtendedBufRead<'a> + ?Sized + 'a + Unpin> ExtendedBufRead<'a> for B
}
fn reset(&mut self, version: Protocol) {
self.deref_mut().reset(version)
self.deref_mut().reset(version);
}
fn stopped_at(&self) -> Option<MessageKind> {
@@ -113,7 +113,7 @@ impl<'a, T: AsyncRead + Unpin> ReadlineBufRead for gix_packetline::read::WithSid
#[async_trait(?Send)]
impl<'a, T: AsyncRead + Unpin> ExtendedBufRead<'a> for gix_packetline::read::WithSidebands<'a, T, HandleProgress<'a>> {
fn set_progress_handler(&mut self, handle_progress: Option<HandleProgress<'a>>) {
self.set_progress_handler(handle_progress)
self.set_progress_handler(handle_progress);
}
async fn peek_data_line(&mut self) -> Option<io::Result<Result<&[u8], Error>>> {
match self.peek_data_line().await {

2
gix/tests/repository/config/transport_options.rs
View File

@@ -83,7 +83,7 @@ mod http {
assert!(
backend.is_none(),
"backed is never set as it's backend specific, rather custom options typically"
)
);
}
#[cfg(feature = "blocking-http-transport-curl")]
{