1. May 11, 2022
  2. May 06, 2022
  3. May 04, 2022
  4. May 03, 2022
  5. Apr 29, 2022
    • Niklas Adolfsson's avatar
      fix(rpc module): close subscription task when a subscription is `unsubscribed`... · 8e945de4
      Niklas Adolfsson authored
      fix(rpc module): close subscription task when a subscription is `unsubscribed` via the `unsubscribe call` (#743)
      
      * refactor: remove SubscriptionSink::inner_send
      
      * fix: close running task if unsubscribed
      
      * Update core/src/server/rpc_module.rs
      
      * Update core/src/server/rpc_module.rs
      
      * fix nits
      
      * Update core/src/server/rpc_module.rs
      
      * add test for canceling subscriptions
      
      * print subscription info; once per minute
      
      * revert closure stuff
      
      * Revert "print subscription info; once per minute"
      
      This reverts commit 366176a8
      
      .
      
      * use tokio::sync::watch instead of oneshot
      
      The receiver is clonable and it's possible to check whether the sender is still alive
      
      * Update tests/tests/helpers.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * grumbles: use unwrap in tests
      
      * add test for reuse pipe_from_stream
      
      Co-authored-by: default avatarDavid <[email protected]>
      8e945de4
    • Sergejs Kostjucenko's avatar
      remove vault from ci (#745) · 9decd23c
      Sergejs Kostjucenko authored
      9decd23c
  6. Apr 21, 2022
  7. Apr 20, 2022
    • Niklas Adolfsson's avatar
      feat: WASM client via web-sys transport (#648) · 20e6e5de
      Niklas Adolfsson authored
      
      
      * feat: untested web-sys transport
      
      * rewrite me
      
      * make it work
      
      * add hacks and works :)
      
      * add subscription test too
      
      * revert StdError change; still works
      
      * cleanup
      
      * remove hacks
      
      * more wasm tests outside workspace
      
      * kill mutually exclusive features
      
      * merge nits
      
      * remove unsafe hack
      
      * fix nit
      
      * core: fix features and deps
      
      * ci: add WASM test
      
      * test again
      
      * work work
      
      * comeon
      
      * work work
      
      * revert unintentional change
      
      * Update core/Cargo.toml
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update core/src/client/async_client/mod.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * revert needless change: std hashmap + fxhashmap works
      
      * cleanup
      
      * extract try_connect_until fn
      
      * remove todo
      
      * fix bad merge
      
      * add wasm client wrapper crate
      
      * fix nits
      
      * use gloo-net dependency
      
      * fix build
      
      * grumbles CI: rename to `wasm_tests`
      
      * fix bad merge
      
      * fix grumbles
      
      * fix nit
      
      * comeon CI
      
      Co-authored-by: default avatarDavid <[email protected]>
      20e6e5de
    • Niklas Adolfsson's avatar
      fix(rpc module): fail subscription calls with bad params (#728) · 9fa817d9
      Niklas Adolfsson authored
      
      
      * fix(rpc module): fail subscription with bad params
      
      * draft; show my point
      
      * fix tests
      
      * fix build
      
      * add tests for proc macros too
      
      * add tests for bad params in proc macros
      
      * fix nits
      
      * commit all files
      
      * add ugly fix for proc macro code
      
      * add more user friendly API
      
      * make SubscriptionSink::close take mut self
      
      * fix grumbles
      
      * show james some code
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      
      * remove needless clone
      
      * fix build
      
      * client fix docs + error type
      
      * simplify code: merge connect reset and unsubscribe close reason
      
      * remove unknown close reason
      
      * refactor: remove Error::SubscriptionClosed
      
      * add some nice APIs to ErrorObjectOwned
      
      * unify api
      
      * address grumbles
      
      * remove redundant methods for close and reject
      
      * proc macro: compile err when subscription -> Result
      
      * rpc module: fix test subscription test
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      
      * Update proc-macros/src/lib.rs
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      
      * address grumbles
      
      * remove faulty comment
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * Update core/src/server/rpc_module.rs
      
      Co-authored-by: default avatarDavid <[email protected]>
      
      * fix: don't send `RPC Call failed: error`.
      
      * remove debug assert
      
      Co-authored-by: default avatarJames Wilson <[email protected]>
      Co-authored-by: default avatarDavid <[email protected]>
      9fa817d9
  8. Apr 12, 2022
  9. Apr 05, 2022
  10. Apr 04, 2022
  11. Apr 02, 2022
    • Niklas Adolfsson's avatar
      [examples]: update pubsub examples (#705) · 961e6bd5
      Niklas Adolfsson authored
      * 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
      961e6bd5
  12. Apr 01, 2022
    • Niklas Adolfsson's avatar
      feat(http server): add new builder APIs `build_from_tcp` and `build_from_hyper` (#719) · 34c2fbef
      Niklas Adolfsson authored
      * 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
      34c2fbef
    • Niklas Adolfsson's avatar
      fix(client): close subscription when server sent `SubscriptionClosed` notification (#721) · f55ab3e3
      Niklas Adolfsson authored
      * fix(client): close subscription when server sent `SubscriptionClosed` notification
      
      * Update core/src/client/async_client/helpers.rs
      f55ab3e3
    • Niklas Adolfsson's avatar
      feat: add `SubscriptionSink::pipe_from_try_stream` to support streams that returns `Result` (#720) · 545ceaf6
      Niklas Adolfsson authored
      
      
      * 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: default avatarTarik 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: default avatarTarik Gul <[email protected]>
      545ceaf6
  13. Mar 30, 2022
  14. Mar 29, 2022
  15. Mar 28, 2022
  16. Mar 22, 2022
  17. Mar 09, 2022
  18. Mar 02, 2022
  19. Feb 22, 2022
  20. Feb 18, 2022
  21. Feb 16, 2022
  22. Feb 11, 2022
  23. Feb 09, 2022
  24. Feb 03, 2022