Replace unnecessary exchange util.

Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk
2025-11-27 06:09:26 +00:00
parent 52b156e034
commit 8f54d9dc09
5 changed files with 13 additions and 15 deletions

View File

@@ -1,7 +1,7 @@
use std::io::Write;
use std::{io::Write, mem::replace};
use serde::{Deserialize, Serialize, ser};
use tuwunel_core::{Error, Result, debug::type_name, err, result::DebugInspect, utils::exchange};
use tuwunel_core::{Error, Result, debug::type_name, err, result::DebugInspect};
use crate::util::unhandled;
@@ -97,7 +97,7 @@ impl<W: Write> Serializer<'_, W> {
fn record_start(&mut self) -> Result {
debug_assert!(!self.is_finalized(), "Starting a record after serialization finalized");
exchange(&mut self.sep, true)
replace(&mut self.sep, true)
.then(|| self.separator())
.unwrap_or(Ok(()))
}

View File

@@ -3,10 +3,10 @@ mod items_rev;
mod keys;
mod keys_rev;
use std::sync::Arc;
use std::{mem::replace, sync::Arc};
use rocksdb::{DBRawIteratorWithThreadMode, ReadOptions};
use tuwunel_core::{Result, utils::exchange};
use tuwunel_core::Result;
pub(crate) use self::{items::Items, items_rev::ItemsRev, keys::Keys, keys_rev::KeysRev};
use crate::{
@@ -94,7 +94,7 @@ impl<'a> State<'a> {
#[inline]
#[cfg_attr(unabridged, tracing::instrument(level = "trace", skip_all))]
pub(super) fn seek_fwd(&mut self) {
if !exchange(&mut self.init, false) {
if !replace(&mut self.init, false) {
self.inner.next();
} else if !self.seek {
self.inner.seek_to_first();
@@ -104,7 +104,7 @@ impl<'a> State<'a> {
#[inline]
#[cfg_attr(unabridged, tracing::instrument(level = "trace", skip_all))]
pub(super) fn seek_rev(&mut self) {
if !exchange(&mut self.init, false) {
if !replace(&mut self.init, false) {
self.inner.prev();
} else if !self.seek {
self.inner.seek_to_last();