Skip to content

Commit 5165d1d

Browse files
committed
make read/write buffers u32 and publ
and remove getter fns
1 parent db6576d commit 5165d1d

File tree

1 file changed

+8
-16
lines changed

1 file changed

+8
-16
lines changed

src/config.rs

+8-16
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,8 @@ pub struct Config {
9191
prefer_dmy: bool,
9292
comment: Option<u8>,
9393
snappy: bool, // flag to enable snappy compression/decompression
94-
read_buffer: usize,
95-
write_buffer: usize,
94+
pub read_buffer: u32,
95+
pub write_buffer: u32,
9696
}
9797

9898
// Empty trait as an alias for Seek and Read that avoids auto trait errors
@@ -203,11 +203,11 @@ impl Config {
203203
read_buffer: std::env::var("QSV_RDR_BUFFER_CAPACITY")
204204
.unwrap_or_else(|_| DEFAULT_RDR_BUFFER_CAPACITY.to_string())
205205
.parse()
206-
.unwrap_or(DEFAULT_RDR_BUFFER_CAPACITY),
206+
.unwrap_or(DEFAULT_RDR_BUFFER_CAPACITY as u32),
207207
write_buffer: std::env::var("QSV_WTR_BUFFER_CAPACITY")
208208
.unwrap_or_else(|_| DEFAULT_WTR_BUFFER_CAPACITY.to_string())
209209
.parse()
210-
.unwrap_or(DEFAULT_WTR_BUFFER_CAPACITY),
210+
.unwrap_or(DEFAULT_WTR_BUFFER_CAPACITY as u32),
211211
}
212212
}
213213

@@ -294,20 +294,12 @@ impl Config {
294294
self
295295
}
296296

297-
pub const fn get_read_buffer(&self) -> usize {
298-
self.read_buffer
299-
}
300-
301-
pub const fn read_buffer(mut self, buffer: usize) -> Config {
297+
pub const fn read_buffer(mut self, buffer: u32) -> Config {
302298
self.read_buffer = buffer;
303299
self
304300
}
305301

306-
pub const fn get_write_buffer(&self) -> usize {
307-
self.write_buffer
308-
}
309-
310-
pub const fn write_buffer(mut self, buffer: usize) -> Config {
302+
pub const fn write_buffer(mut self, buffer: u32) -> Config {
311303
self.write_buffer = buffer;
312304
self
313305
}
@@ -543,7 +535,7 @@ impl Config {
543535
.quote(self.quote)
544536
.quoting(self.quoting)
545537
.escape(self.escape)
546-
.buffer_capacity(self.read_buffer)
538+
.buffer_capacity(self.read_buffer as usize)
547539
.comment(rdr_comment)
548540
.trim(self.trim)
549541
.from_reader(rdr)
@@ -581,7 +573,7 @@ impl Config {
581573
.quote_style(self.quote_style)
582574
.double_quote(self.double_quote)
583575
.escape(self.escape.unwrap_or(b'\\'))
584-
.buffer_capacity(self.write_buffer)
576+
.buffer_capacity(self.write_buffer as usize)
585577
.from_writer(wtr)
586578
}
587579
}

0 commit comments

Comments
 (0)