noth/surrealpatch
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Simplify v.into() value conversion statements

Browse source
This commit is contained in:
Tobie Morgan Hitchcock 2022-07-16 23:18:24 +01:00
parent 38f560c213
commit c9d9b041f7
5 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/src/kvs/file/mod.rs
View file

@ -154,7 +154,7 @@ impl Transaction {
return Err(Error::TxReadonly);
}
// Set the key
self.tx.putc(key.into(), val.into(), chk.map(|v| v.into()))?;
self.tx.putc(key.into(), val.into(), chk.map(Into::into))?;
// Return result
Ok(())
}
@ -191,7 +191,7 @@ impl Transaction {
return Err(Error::TxReadonly);
}
// Remove the key
self.tx.delc(key.into(), chk.map(|v| v.into()))?;
self.tx.delc(key.into(), chk.map(Into::into))?;
// Return result
Ok(())
}

4
lib/src/kvs/ixdb/mod.rs
View file

@ -157,7 +157,7 @@ impl Transaction {
return Err(Error::TxReadonly);
}
// Set the key
self.tx.putc(key.into(), val.into(), chk.map(|v| v.into())).await?;
self.tx.putc(key.into(), val.into(), chk.map(Into::into)).await?;
// Return result
Ok(())
}
@ -194,7 +194,7 @@ impl Transaction {
return Err(Error::TxReadonly);
}
// Remove the key
let res = self.tx.delc(key.into(), chk.map(|v| v.into())).await?;
let res = self.tx.delc(key.into(), chk.map(Into::into)).await?;
// Return result
Ok(res)
}

4
lib/src/kvs/mem/mod.rs
View file

@ -154,7 +154,7 @@ impl Transaction {
return Err(Error::TxReadonly);
}
// Set the key
self.tx.putc(key.into(), val.into(), chk.map(|v| v.into()))?;
self.tx.putc(key.into(), val.into(), chk.map(Into::into))?;
// Return result
Ok(())
}
@ -191,7 +191,7 @@ impl Transaction {
return Err(Error::TxReadonly);
}
// Remove the key
self.tx.delc(key.into(), chk.map(|v| v.into()))?;
self.tx.delc(key.into(), chk.map(Into::into))?;
// Return result
Ok(())
}

4
lib/src/kvs/tikv/mod.rs
View file

@ -171,7 +171,7 @@ impl Transaction {
// Get the val
let val = val.into();
// Get the check
let chk = chk.map(|v| v.into());
let chk = chk.map(Into::into);
// Delete the key
match (self.tx.get(key.clone()).await?, chk) {
(Some(v), Some(w)) if v == w => self.tx.put(key, val).await?,
@ -216,7 +216,7 @@ impl Transaction {
// Get the key
let key = key.into();
// Get the check
let chk = chk.map(|v| v.into());
let chk = chk.map(Into::into);
// Delete the key
match (self.tx.get(key.clone()).await?, chk) {
(Some(v), Some(w)) if v == w => self.tx.delete(key).await?,

6
lib/src/sql/value/get.rs
View file

@ -44,11 +44,11 @@ impl Value {
Part::All => {
let path = path.next();
let futs = v.iter().map(|v| v.get(ctx, opt, txn, path));
try_join_all(futs).await.map(|v| v.into())
try_join_all(futs).await.map(Into::into)
}
Part::Any => {
let futs = v.iter().map(|v| v.get(ctx, opt, txn, path));
try_join_all(futs).await.map(|v| v.into())
try_join_all(futs).await.map(Into::into)
}
Part::First => match v.first() {
Some(v) => v.get(ctx, opt, txn, path.next()).await,
@ -74,7 +74,7 @@ impl Value {
}
_ => {
let futs = v.iter().map(|v| v.get(ctx, opt, txn, path));
try_join_all(futs).await.map(|v| v.into())
try_join_all(futs).await.map(Into::into)
}
},
// Current path part is a thing