reqwest-streams 0.12.0

HTTP body streaming support for reqwest: JSON/CSV/Protobuf and others
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

[![Cargo](https://img.shields.io/crates/v/reqwest-streams.svg)](https://crates.io/crates/reqwest-streams)
![tests and formatting](https://github.com/abdolence/reqwest-streams-rs/workflows/tests%20&%20formatting/badge.svg)
![security audit](https://github.com/abdolence/reqwest-streams-rs/workflows/security%20audit/badge.svg)

# reqwest streams for Rust

Library provides HTTP response streaming support for [reqwest](https://github.com/seanmonstar/reqwest):
- JSON array stream format
- JSON lines stream format
- CSV stream
- Protobuf len-prefixed stream format
- Arrow IPC stream format

This type of responses are useful when you are reading huge stream of objects from some source (such as database, file, etc)
and want to avoid huge memory allocation.

## Quick start

Cargo.toml:
```toml
[dependencies]
reqwest-streams = { version = "0.10", features=["json", "csv", "protobuf", "arrow"] }
```

Example code:
```rust

use reqwest_streams::*;
use futures::stream::BoxStream;
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Deserialize)]
struct MyTestStructure {
    some_test_field: String
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {

    let _stream = reqwest::get("http://localhost:8080/json-array")
        .await?
        .json_array_stream::<MyTestStructure>(1024);

    Ok(())
}
```

All examples available in [examples](examples) directory.

To run example use:
```
# cargo run --example json-stream
```

## Need server support?
There is the same functionality:
- [axum-streams](https://github.com/abdolence/axum-streams-rs).

## Licence
Apache Software License (ASL)

## Author
Abdulla Abdurakhmanov