Expand redacted stream debug state

Author: eldryoth

CHANGELOG.md

@@ -88,6 +88,8 @@
   quantum.
 - Added reader-side stream `buffered_output_capacity()` and
   `buffered_output_remaining_capacity()` helpers for fixed-queue diagnostics.
+- Expanded redacted stream `Debug` output with recovery readiness, pending
+  quantum state, and reader-side fixed output queue capacity.
 
 ## 0.8.0 - 2026-05-16
 

README.md

@@ -570,7 +570,8 @@ Base64 quantum or decoded tail. All stream adapters also expose
 `can_into_inner()` and `try_into_inner()` as checked recovery paths that refuse
 to return the wrapped reader or writer while doing so would discard pending
 input or buffered output. Their `Debug` output reports adapter state without
-formatting the wrapped reader or writer.
+formatting the wrapped reader or writer, including recovery readiness, pending
+quantum state, and reader-side fixed output queue capacity.
 
 URL-safe, no-padding encoding:
 

src/lib.rs

@@ -708,6 +708,8 @@ pub mod stream {
                 .field("engine", &self.engine)
                 .field("pending", &"<redacted>")
                 .field("pending_len", &self.pending_len)
+                .field("pending_input_needed_len", &self.pending_input_needed_len())
+                .field("can_into_inner", &self.can_into_inner())
                 .field("finalized", &self.finalized)
                 .finish()
         }
@@ -1012,6 +1014,8 @@ pub mod stream {
                 .field("engine", &self.engine)
                 .field("pending", &"<redacted>")
                 .field("pending_len", &self.pending_len)
+                .field("pending_input_needed_len", &self.pending_input_needed_len())
+                .field("can_into_inner", &self.can_into_inner())
                 .field("terminal_padding", &self.finished)
                 .field("finalized", &self.finalized)
                 .finish()
@@ -1395,7 +1399,14 @@ pub mod stream {
                 .field("engine", &self.engine)
                 .field("pending", &"<redacted>")
                 .field("pending_len", &self.pending_len)
+                .field("pending_input_needed_len", &self.pending_input_needed_len())
                 .field("buffered_output_len", &self.output.len())
+                .field("buffered_output_capacity", &self.output.capacity())
+                .field(
+                    "buffered_output_remaining_capacity",
+                    &self.output.available_capacity(),
+                )
+                .field("can_into_inner", &self.can_into_inner())
                 .field("finished", &self.finished)
                 .field("terminal_padding", &self.terminal_seen)
                 .finish()
@@ -1701,7 +1712,14 @@ pub mod stream {
                 .field("engine", &self.engine)
                 .field("pending", &"<redacted>")
                 .field("pending_len", &self.pending_len)
+                .field("pending_input_needed_len", &self.pending_input_needed_len())
                 .field("buffered_output_len", &self.output.len())
+                .field("buffered_output_capacity", &self.output.capacity())
+                .field(
+                    "buffered_output_remaining_capacity",
+                    &self.output.available_capacity(),
+                )
+                .field("can_into_inner", &self.can_into_inner())
                 .field("finished", &self.finished)
                 .finish()
         }

tests/rfc4648.rs

@@ -3527,13 +3527,17 @@ fn stream_debug_output_redacts_wrapped_io() {
     let debug = format!("{encoder:?}");
     assert!(debug.contains("Encoder"));
     assert!(debug.contains("pending_len"));
+    assert!(debug.contains("pending_input_needed_len"));
+    assert!(debug.contains("can_into_inner"));
     assert!(debug.contains("<present>"));
     assert!(!debug.contains("raw-secret"));
 
     let mut decoder = Decoder::new(b"decoded-secret".to_vec(), STANDARD);
     decoder.write_all(b"aGk=").unwrap();
     let debug = format!("{decoder:?}");
     assert!(debug.contains("Decoder"));
+    assert!(debug.contains("pending_input_needed_len"));
+    assert!(debug.contains("can_into_inner"));
     assert!(debug.contains("terminal_padding"));
     assert!(!debug.contains("decoded-secret"));
 
@@ -3542,14 +3546,22 @@ fn stream_debug_output_redacts_wrapped_io() {
     decoder_reader.read_exact(&mut one).unwrap();
     let debug = format!("{decoder_reader:?}");
     assert!(debug.contains("DecoderReader"));
+    assert!(debug.contains("pending_input_needed_len"));
     assert!(debug.contains("buffered_output_len"));
+    assert!(debug.contains("buffered_output_capacity"));
+    assert!(debug.contains("buffered_output_remaining_capacity"));
+    assert!(debug.contains("can_into_inner"));
     assert!(!debug.contains("aGVsbG8"));
 
     let mut encoder_reader = EncoderReader::new(Cursor::new(&b"raw-secret"[..]), STANDARD);
     encoder_reader.read_exact(&mut one).unwrap();
     let debug = format!("{encoder_reader:?}");
     assert!(debug.contains("EncoderReader"));
+    assert!(debug.contains("pending_input_needed_len"));
     assert!(debug.contains("buffered_output_len"));
+    assert!(debug.contains("buffered_output_capacity"));
+    assert!(debug.contains("buffered_output_remaining_capacity"));
+    assert!(debug.contains("can_into_inner"));
     assert!(!debug.contains("raw-secret"));
 }