aboutsummaryrefslogtreecommitdiff
path: root/vendor/anstream/src/strip.rs
diff options
context:
space:
mode:
authorValentin Popov <valentin@popov.link>2024-07-19 15:37:58 +0300
committerValentin Popov <valentin@popov.link>2024-07-19 15:37:58 +0300
commita990de90fe41456a23e58bd087d2f107d321f3a1 (patch)
tree15afc392522a9e85dc3332235e311b7d39352ea9 /vendor/anstream/src/strip.rs
parent3d48cd3f81164bbfc1a755dc1d4a9a02f98c8ddd (diff)
downloadfparkan-a990de90fe41456a23e58bd087d2f107d321f3a1.tar.xz
fparkan-a990de90fe41456a23e58bd087d2f107d321f3a1.zip
Deleted vendor folder
Diffstat (limited to 'vendor/anstream/src/strip.rs')
-rw-r--r--vendor/anstream/src/strip.rs219
1 files changed, 0 insertions, 219 deletions
diff --git a/vendor/anstream/src/strip.rs b/vendor/anstream/src/strip.rs
deleted file mode 100644
index d7fda04..0000000
--- a/vendor/anstream/src/strip.rs
+++ /dev/null
@@ -1,219 +0,0 @@
-use crate::adapter::StripBytes;
-use crate::stream::AsLockedWrite;
-use crate::stream::RawStream;
-
-/// Only pass printable data to the inner `Write`
-#[derive(Debug)]
-pub struct StripStream<S>
-where
- S: RawStream,
-{
- raw: S,
- state: StripBytes,
-}
-
-impl<S> StripStream<S>
-where
- S: RawStream,
-{
- /// Only pass printable data to the inner `Write`
- #[inline]
- pub fn new(raw: S) -> Self {
- Self {
- raw,
- state: Default::default(),
- }
- }
-
- /// Get the wrapped [`RawStream`]
- #[inline]
- pub fn into_inner(self) -> S {
- self.raw
- }
-
- #[inline]
- pub fn is_terminal(&self) -> bool {
- self.raw.is_terminal()
- }
-}
-
-impl StripStream<std::io::Stdout> {
- /// Get exclusive access to the `StripStream`
- ///
- /// Why?
- /// - Faster performance when writing in a loop
- /// - Avoid other threads interleaving output with the current thread
- #[inline]
- pub fn lock(self) -> StripStream<std::io::StdoutLock<'static>> {
- StripStream {
- raw: self.raw.lock(),
- state: self.state,
- }
- }
-}
-
-impl StripStream<std::io::Stderr> {
- /// Get exclusive access to the `StripStream`
- ///
- /// Why?
- /// - Faster performance when writing in a loop
- /// - Avoid other threads interleaving output with the current thread
- #[inline]
- pub fn lock(self) -> StripStream<std::io::StderrLock<'static>> {
- StripStream {
- raw: self.raw.lock(),
- state: self.state,
- }
- }
-}
-
-impl<S> std::io::Write for StripStream<S>
-where
- S: RawStream + AsLockedWrite,
-{
- // Must forward all calls to ensure locking happens appropriately
- #[inline]
- fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> {
- write(&mut self.raw.as_locked_write(), &mut self.state, buf)
- }
- #[inline]
- fn write_vectored(&mut self, bufs: &[std::io::IoSlice<'_>]) -> std::io::Result<usize> {
- let buf = bufs
- .iter()
- .find(|b| !b.is_empty())
- .map(|b| &**b)
- .unwrap_or(&[][..]);
- self.write(buf)
- }
- // is_write_vectored: nightly only
- #[inline]
- fn flush(&mut self) -> std::io::Result<()> {
- self.raw.as_locked_write().flush()
- }
- #[inline]
- fn write_all(&mut self, buf: &[u8]) -> std::io::Result<()> {
- write_all(&mut self.raw.as_locked_write(), &mut self.state, buf)
- }
- // write_all_vectored: nightly only
- #[inline]
- fn write_fmt(&mut self, args: std::fmt::Arguments<'_>) -> std::io::Result<()> {
- write_fmt(&mut self.raw.as_locked_write(), &mut self.state, args)
- }
-}
-
-fn write(
- raw: &mut dyn std::io::Write,
- state: &mut StripBytes,
- buf: &[u8],
-) -> std::io::Result<usize> {
- let initial_state = state.clone();
-
- for printable in state.strip_next(buf) {
- let possible = printable.len();
- let written = raw.write(printable)?;
- if possible != written {
- let divergence = &printable[written..];
- let offset = offset_to(buf, divergence);
- let consumed = &buf[offset..];
- *state = initial_state;
- state.strip_next(consumed).last();
- return Ok(offset);
- }
- }
- Ok(buf.len())
-}
-
-fn write_all(
- raw: &mut dyn std::io::Write,
- state: &mut StripBytes,
- buf: &[u8],
-) -> std::io::Result<()> {
- for printable in state.strip_next(buf) {
- raw.write_all(printable)?;
- }
- Ok(())
-}
-
-fn write_fmt(
- raw: &mut dyn std::io::Write,
- state: &mut StripBytes,
- args: std::fmt::Arguments<'_>,
-) -> std::io::Result<()> {
- let write_all = |buf: &[u8]| write_all(raw, state, buf);
- crate::fmt::Adapter::new(write_all).write_fmt(args)
-}
-
-#[inline]
-fn offset_to(total: &[u8], subslice: &[u8]) -> usize {
- let total = total.as_ptr();
- let subslice = subslice.as_ptr();
-
- debug_assert!(
- total <= subslice,
- "`Offset::offset_to` only accepts slices of `self`"
- );
- subslice as usize - total as usize
-}
-
-#[cfg(test)]
-mod test {
- use super::*;
- use proptest::prelude::*;
- use std::io::Write as _;
-
- proptest! {
- #[test]
- #[cfg_attr(miri, ignore)] // See https://github.com/AltSysrq/proptest/issues/253
- fn write_all_no_escapes(s in "\\PC*") {
- let buffer = Vec::new();
- let mut stream = StripStream::new(buffer);
- stream.write_all(s.as_bytes()).unwrap();
- let buffer = stream.into_inner();
- let actual = std::str::from_utf8(buffer.as_ref()).unwrap();
- assert_eq!(s, actual);
- }
-
- #[test]
- #[cfg_attr(miri, ignore)] // See https://github.com/AltSysrq/proptest/issues/253
- fn write_byte_no_escapes(s in "\\PC*") {
- let buffer = Vec::new();
- let mut stream = StripStream::new(buffer);
- for byte in s.as_bytes() {
- stream.write_all(&[*byte]).unwrap();
- }
- let buffer = stream.into_inner();
- let actual = std::str::from_utf8(buffer.as_ref()).unwrap();
- assert_eq!(s, actual);
- }
-
- #[test]
- #[cfg_attr(miri, ignore)] // See https://github.com/AltSysrq/proptest/issues/253
- fn write_all_random(s in any::<Vec<u8>>()) {
- let buffer = Vec::new();
- let mut stream = StripStream::new(buffer);
- stream.write_all(s.as_slice()).unwrap();
- let buffer = stream.into_inner();
- if let Ok(actual) = std::str::from_utf8(buffer.as_ref()) {
- for char in actual.chars() {
- assert!(!char.is_ascii() || !char.is_control() || char.is_ascii_whitespace(), "{:?} -> {:?}: {:?}", String::from_utf8_lossy(&s), actual, char);
- }
- }
- }
-
- #[test]
- #[cfg_attr(miri, ignore)] // See https://github.com/AltSysrq/proptest/issues/253
- fn write_byte_random(s in any::<Vec<u8>>()) {
- let buffer = Vec::new();
- let mut stream = StripStream::new(buffer);
- for byte in s.as_slice() {
- stream.write_all(&[*byte]).unwrap();
- }
- let buffer = stream.into_inner();
- if let Ok(actual) = std::str::from_utf8(buffer.as_ref()) {
- for char in actual.chars() {
- assert!(!char.is_ascii() || !char.is_control() || char.is_ascii_whitespace(), "{:?} -> {:?}: {:?}", String::from_utf8_lossy(&s), actual, char);
- }
- }
- }
- }
-}