streamson-tokio 0.2.0

Tokio and streamson integration library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

# Streamson tokio

A library which integrates streamson with tokio.
So that you can easily split jsons using asynchronous rust.

## Examples
### Reading a large file
```rust
 use std::io;
 use streamson_lib::error;
 use streamson_tokio::decoder::SimpleExtractor;
 use tokio::{fs, stream::StreamExt};
 use tokio_util::codec::FramedRead;

 let mut file = fs::File::open("/tmp/large.json").await?;
 let extractor = SimpleExtractor::new(vec![r#"{"users"}[]"#, r#"{"groups"}[]"#]);
 let mut output = FramedRead::new(file, extractor);
 while let Some(item) = output.next().await {
	 let (path, data) = item?;
	 // Do something with extracted data
 }
```