Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

tokio-stream: add wrapper for broadcast and watch #3384

Merged
merged 19 commits into from
Feb 5, 2021
Merged

tokio-stream: add wrapper for broadcast and watch #3384

merged 19 commits into from
Feb 5, 2021

Commits on Jan 31, 2021

  1. tokio-stream: add wrapper for broadcast 

    Signed-off-by: Fuyang Liu <liufuyang@users.noreply.github.com>
    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    eddbdaa View commit details
    Browse the repository at this point in the history

  2. Fix up 

    Signed-off-by: Fuyang Liu <liufuyang@users.noreply.github.com>
    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    f1094aa View commit details
    Browse the repository at this point in the history

  3. Minor fixup - remove cfg_attr

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    6995914 View commit details
    Browse the repository at this point in the history

  4. Add #[derive(Debug)]

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    5229cad View commit details
    Browse the repository at this point in the history

  5. Update tokio-stream/src/wrappers/broadcast.rs 

    Co-authored-by: Alice Ryhl <alice@ryhl.io>
    @liufuyang @Darksonn
    liufuyang and Darksonn committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    c611d5c View commit details
    Browse the repository at this point in the history

  6. return Lagged error

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    1977be3 View commit details
    Browse the repository at this point in the history

  7. expose BroadcastStreamRecvError

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    d9fd015 View commit details
    Browse the repository at this point in the history

  8. reformat

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    9513b71 View commit details
    Browse the repository at this point in the history

  9. add watch (#1) 

    * add watch

* Fix up
    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    ed00803 View commit details
    Browse the repository at this point in the history

  10. return cloned value when warpped recv changed

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    ef12286 View commit details
    Browse the repository at this point in the history

  11. remove dependency of async_stream

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    34eab73 View commit details
    Browse the repository at this point in the history

  12. Update tokio-stream/Cargo.toml 

    Co-authored-by: Alice Ryhl <alice@ryhl.io>
    @liufuyang @Darksonn
    liufuyang and Darksonn authored Jan 31, 2021
    Configuration menu
    Copy the full SHA
    c6f9ee9 View commit details
    Browse the repository at this point in the history

  13. wrap the receiver in an inner error

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    35a8502 View commit details
    Browse the repository at this point in the history

  14. fix up

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    2cbf560 View commit details
    Browse the repository at this point in the history

  15. simplify code

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    e2d8214 View commit details
    Browse the repository at this point in the history

  16. alwasy refresh inner future

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    f7f2f00 View commit details
    Browse the repository at this point in the history

  17. add async-stream back for dev dep

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    fb244b1 View commit details
    Browse the repository at this point in the history

  18. simplify code

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    3b045dc View commit details
    Browse the repository at this point in the history

  19. fix up

    @liufuyang
    liufuyang committed Jan 31, 2021
    Configuration menu
    Copy the full SHA
    d44d54a View commit details
    Browse the repository at this point in the history