|
|
@@ -150,6 +150,7 @@ impl<R: Read> BlobReader<R> {
|
|
150
|
150
|
///
|
|
151
|
151
|
/// # Ok(())
|
|
152
|
152
|
/// # }
|
|
|
153
|
+ /// # foo().unwrap();
|
|
153
|
154
|
/// ```
|
|
154
|
155
|
pub fn new(reader: R) -> BlobReader<R> {
|
|
155
|
156
|
BlobReader {
|
|
|
@@ -174,6 +175,7 @@ impl BlobReader<BufReader<File>> {
|
|
174
|
175
|
/// let reader = BlobReader::from_path("tests/test.osm.pbf")?;
|
|
175
|
176
|
/// # Ok(())
|
|
176
|
177
|
/// # }
|
|
|
178
|
+ /// # foo().unwrap();
|
|
177
|
179
|
/// ```
|
|
178
|
180
|
pub fn from_path<P: AsRef<Path>>(path: P) -> Result<Self>
|
|
179
|
181
|
{
|
|
|
@@ -265,9 +267,10 @@ impl<R: Read + Seek> BlobReader<R> {
|
|
265
|
267
|
/// let mut reader = BlobReader::new_seekable(buf_reader)?;
|
|
266
|
268
|
/// let first_blob = reader.next().unwrap()?;
|
|
267
|
269
|
///
|
|
268
|
|
- /// assert_eq!(first_blob.offset(), Some(ByteOffset(1)));
|
|
|
270
|
+ /// assert_eq!(first_blob.offset(), Some(ByteOffset(0)));
|
|
269
|
271
|
/// # Ok(())
|
|
270
|
272
|
/// # }
|
|
|
273
|
+ /// # foo().unwrap();
|
|
271
|
274
|
/// ```
|
|
272
|
275
|
pub fn new_seekable(mut reader: R) -> Result<BlobReader<R>> {
|
|
273
|
276
|
let pos = reader.seek(SeekFrom::Current(0))?;
|
|
|
@@ -296,6 +299,7 @@ impl<R: Read + Seek> BlobReader<R> {
|
|
296
|
299
|
/// assert_eq!(first_blob.offset(), first_blob_again.offset());
|
|
297
|
300
|
/// # Ok(())
|
|
298
|
301
|
/// # }
|
|
|
302
|
+ /// # foo().unwrap();
|
|
299
|
303
|
/// ```
|
|
300
|
304
|
pub fn seek(&mut self, pos: ByteOffset) -> Result<()> {
|
|
301
|
305
|
match self.reader.seek(SeekFrom::Start(pos.0)) {
|