Paul Loyd

Update clickhouse.rs & disable compression

1

10s → 4s. Not amazing, but more relevant numbers. Regenerate results, please

Benchmarks should be more accurate, more attention to details please

1

Thanks for benchmarking. I've noticed that not all libraries are in the same condition. For instance, `loyd/clickhouse.rs` uses LZ4 by default, that's a reasonable default, but the best library uses...

Integration with the `tracing` crate

1

First of all, thanks for the great crate. I've been waiting for a similar library for a long time. I highly like the idea of having a custom handler, because...

The counter metrics about the number of sent/received events in streams

2

### What problem are you trying to solve? Hi, I'm choosing between linkerd (first of all because the proxy is written in Rust, which is lightweight on my tests) and...

Provide collect()

1

Provide polymorphic `collect()` instead of bunch of the fns (`toArray`, `toString`, `toObject` etc). Api (can easily be described in ts or flow): ```js new Iter(...).collect(Array); new Iter(...).collect(String); new Iter(...).collect(Map); new...

Now it's hardcoded: ```rust const BACKOFF_STEP: Duration = Duration::from_secs(5); const MAX_BACKOFF: Duration = Duration::from_secs(30); ```

Proxy: methods to test failed `send()`

1

Now `send()` panics if there is an error. Sometimes it's useful to check it.

Some variants: 

Introduce link-like functionality as a primitive for subscription implementations. [Sketch](https://play.rust-lang.org/?version=stable&mode=debug&edition=2021&gist=905b58cd49120309395ab4b481479dbc)

Non-blocking requests

4

API for non-blocking requests. Something like this: ```rust #[message(ret = u32)] struct SomeRequest(u32); let request_map = RequestMap::new(); // `SecondaryMap` underhood let request_id = ctx.request(SomeRequest(42)).id().await; // Store additional information request_map.insert(request_id, SomeInfo...