From f39a39f4ce14557ec58b8eec2c4cab9017d74423 Mon Sep 17 00:00:00 2001 From: John Anderson Date: Mon, 29 Apr 2024 16:59:44 -0400 Subject: [PATCH] minor tweak and comment --- src/rapid.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/rapid.rs b/src/rapid.rs index c7e2e1a..0178b9d 100644 --- a/src/rapid.rs +++ b/src/rapid.rs @@ -169,6 +169,8 @@ pub mod ffi { fn Take(self : &mut RustStream) -> c_char; // position in stream fn Tell(self : &RustStream) -> usize; + + // These can remain unimplemented for read-only streams unsafe fn PutBegin(self : &mut RustStream) -> c_char; fn Put(self : &mut RustStream, one : c_char); fn Flush(self : &mut RustStream); @@ -231,7 +233,7 @@ struct ChannelStreamer(rtrb::Consumer>, std::thread::Thread); use crate::parser::JsonEvents; -impl<'l> JsonEvents<'_,String> for ChannelStreamer { +impl JsonEvents<'_,String> for ChannelStreamer { #[inline] fn next_event<'a>(&'a mut self) -> std::result::Result, Box<(dyn std::error::Error + 'static)>> { while !self.0.is_abandoned() {