Commit 21a59f3
Streaming proposals (#53)
* Support new Aetherdrift card variants
* Streaming improvements
* Clean up the code, remove duplucations, non caching reader is still not implemented
* Implement memory efficient response to serde streaming without keeping the whole body in memory
* Fix some warnings
* Bump ureq to v3.0.4
* Elminate blocking request
* Implement tokio based async streaming of bulk lists
* Use tokio::fs to create bulk cache file
* Re-enable strictness test
* Update src/util/streaming_deserializer.rs
Co-authored-by: Mendes <pedro.mendes.26@gmail.com>
* Update src/bulk.rs
Co-authored-by: Mendes <pedro.mendes.26@gmail.com>
* Remove trait bound
* Add missing import
* Use Unpin bound instead of explicit pinning
* Use bound channel and block in the dedicated thread
* Fix use blocking send in blocking thread
---------
Co-authored-by: Mendes <pedro.mendes.26@gmail.com>1 parent 0a4b334 commit 21a59f3
7 files changed
Lines changed: 429 additions & 397 deletions
File tree
- examples/bulk
- src
- util
0 commit comments