Co-authored-by: Tarik Gul <[email protected]>

* improve benches with 10 requests per conn

* add subscription bench

* fix nits

* fix nit run 256 too

* add CPU profiling via pprof

* rewrite me

* add move benchmark methods; fast, slow & memory intensive

* add instructions for ulimit

* reduce mem call not reach 256MB limit in WS for batches

* update pubsub examples

* Update examples/ws_subscription.rs

* remove some docs

* remove needless clone

* simplify example

* simplify code with async-broadcast channel

* use tokio broadcast for smaller dependency tree

* Update examples/ws_pubsub_broadcast.rs

* unify servers; use tokio::TcpListener

* add API to build server from tcp socket

* build_from_tcp nit: not async

* fix nits

* change `build_from_tcp` force users configure hyper

The hyper settings might contradict to settings on the provided
socket, force users of this API to configure that avoid confusion and
unexpected settings.

* Update http-server/src/server.rs

* fix doc links

* add separate APIs `build_from_tcp` and `build_from_hyper`

* fix clippy

* remove dead code

* fix build

* fix nit in example code

* fix(client): close subscription when server sent `SubscriptionClosed` notification

* Update core/src/client/async_client/helpers.rs

* refactor: make `pipe_from_stream` take stream of result

The rationale for this is that it is more flexible for use cases when `Stream<Item = Result<T, Error>>`.

Take for example `tokio_stream::Broadcast` then one would have to something like:

```rust
   let stream = BroadcastStream::new(rx).take_while(|r| future::ready(r.is_ok())).filter_map(|r| future::ready(r.ok()));
```

Of course it's a bit awkward to return `Result` when the underlying stream can't fail but I think that's fair trade-off
here.

* Update core/src/server/rpc_module.rs

Co-authored-by: Tarik Gul <[email protected]>

* pipe_from_stream: make E: Display instead of StdError

* add a test

* add `pipe_from_try_stream` API to support `TryStream`

* Update tests/tests/integration_tests.rs

* Update proc-macros/src/lib.rs

Co-authored-by: Tarik Gul <[email protected]>

* refactor: get rid off `Error::Request` variant

* fix nit

* to_owned -> to_call_error

* fix(http client): set reuseaddr and nodelay.

* configure socket for https too

* http server: `set_reuse_port`

* fix windows build

* revert http server changes

* fix build with latest syn

* fix: max_request_body_size setting should not override max_response_size

* chore: apply review comment

* wip wip wip

Use tokio::sync::Notify to signal to the server when a subscriber has gone away without calling unsubscribe

* Cleanup

* Fmt

* More cleanup more TODOs

* fmt

* Address a few todos

* Update core/src/server/rpc_module.rs

Co-authored-by: Niklas Adolfsson <[email protected]>

* Update ws-server/src/server.rs

Co-authored-by: Niklas Adolfsson <[email protected]>

* Fix bad merge

* Test

* fmt

* fix test

* Finish test

* Cleanup
Add a second subscription to serverless test

* Update tests/tests/integration_tests.rs

Co-authored-by: Niklas Adolfsson <[email protected]>

* simplify test

* Review feedback: avoid allocations

* cleanup

* Remove async-channel

* remove async-channel deps

Co-authored-by: Niklas Adolfsson <[email protected]>

Bumps [actions/checkout](https://github.com/actions/checkout) from 2.4.0 to 3.
- [Release notes](https://github.com/actions/checkout/releases)
- [Changelog](https://github.com/actions/checkout/blob/main/CHANGELOG.md)
- [Commits](https://github.com/actions/checkout/compare/v2.4.0...v3

)

---
updated-dependencies:
- dependency-name: actions/checkout
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <[email protected]>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* fix(rpc module): unsubscribe ethereum pubsub spec

* update docs

* fix clippy

* fix tests

* [proc macros]: only generate unsub if not provided

* Update proc-macros/src/rpc_macro.rs

Co-authored-by: David <[email protected]>

* Update proc-macros/src/lib.rs

Co-authored-by: David <[email protected]>

* fix grumbles

* Update proc-macros/src/lib.rs

Co-authored-by: David <[email protected]>

* Update proc-macros/src/lib.rs

Co-authored-by: David <[email protected]>

* Update proc-macros/src/lib.rs

Co-authored-by: David <[email protected]>

* Update proc-macros/tests/ui/correct/alias_doesnt_use_namespace.rs

Co-authored-by: David <[email protected]>

Co-authored-by: David <[email protected]>

Co-authored-by: CI system <>

* CI: try nextest

* CI: nextest for mac and wim

Co-authored-by: CI system <>

Updates the requirements on [tokio-util](https://github.com/tokio-rs/tokio) to permit the latest version.
- [Release notes](https://github.com/tokio-rs/tokio/releases)
- [Commits](https://github.com/tokio-rs/tokio/commits

)

---
updated-dependencies:
- dependency-name: tokio-util
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <[email protected]>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* Release prep for v0.9

* Update CHANGELOG
Don't dry-run when releasing

* Tweak release notes

* Update CHANGELOG.md

Co-authored-by: Niklas Adolfsson <[email protected]>

Co-authored-by: Niklas Adolfsson <[email protected]>

* refactor(ws server): set_id_provider `Box<dyn>`

* address grumbles: thanks James

* relax trait bounds with ?Sized

* Update ws-server/src/tests.rs

* add docs

Updates the requirements on [parking_lot](https://github.com/Amanieu/parking_lot) to permit the latest version.
- [Release notes](https://github.com/Amanieu/parking_lot/releases)
- [Changelog](https://github.com/Amanieu/parking_lot/blob/master/CHANGELOG.md)
- [Commits](https://github.com/Amanieu/parking_lot/compare/0.11.0...0.12.0

)

---
updated-dependencies:
- dependency-name: parking_lot
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <[email protected]>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

The `crate` is rather stable now, so I think it makes sense to remove that from the README

* Prep for releasing v0.8.0

* Grumble

* feat(client): support request id as Strings.

* add tests for Id::String

* address grumbles: move id_kind to RequestManager

* Update client/http-client/src/client.rs

* types: take ref to `ID` get rid of some `Clone`

* remove more clone

* grumbles: rename tests

Add a method to RpcModule that transforms the module into a `RpcModule<()>`, i.e. removes the context. (#660)

* Add a method to RpcModule, `decontextualize`, that transforms the module into a `RpcModule<()>`, i.e. removes the context.

* Merging a module with an empty module cannot fail

* fmt

* Address grumbles

* Cleanup macro

* Update core/src/server/rpc_module.rs

Co-authored-by: Maciej Hirsz <[email protected]>

Co-authored-by: Maciej Hirsz <[email protected]>

* feat(rpc module): add_stream to subscription sink

* fix some nits

* unify parameters to rpc methods

* Update core/src/server/rpc_module.rs

* Update tests/tests/integration_tests.rs

Co-authored-by: David <[email protected]>

* address grumbles

* fix subscription tests

* new type for `SubscriptionCallback` and glue code

* remove unsed code

* remove todo

* add missing feature tokio/macros

* make `add_stream` cancel-safe

* rename add_stream and return status

* fix nits

* rename stream API -> streamify

* Update core/src/server/rpc_module.rs

* provide proper close reason

* spelling

* consume_and_streamify + docs

* fmt

* rename API pipe_from_stream

* improve logging; indicate which subscription method that failed

Co-authored-by: David <[email protected]>