Code

Add recv_many for mpsc channels#6010

Code

Merged

Darksonn merged 37 commits intotokio-rs:mastertokio-rs/tokio:masterfrom aschweig:recv_manyCopy head branch name to clipboardOct 17, 2023

+545-5

Commits

Commits on Oct 9, 2023

• Method recv_many returns a Vec<T> for mpsc channels

  Show description for f13ea3e
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  f13ea3e

  Copy full SHA for f13ea3e

• Update recv_many to populate a passed-in buffer.

  Show description for 0133425
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  0133425

  Copy full SHA for 0133425

• fix rustfmt issues

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  7d0d8db

  Copy full SHA for 7d0d8db

• fix returning the result of a binding from a block

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  487f887

  Copy full SHA for 487f887

• fix rustfmt braces around continue

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  7086b34

  Copy full SHA for 7086b34

• Update from bencher and merge benchmarks into sync_mpsc.rs

  Show description for 9a170b0
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  9a170b0

  Copy full SHA for 9a170b0

• fix Cargo.toml to reflect deletion of old benchmark

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  01b2270

  Copy full SHA for 01b2270

• Simplified recv_many implementation

  Show description for 8c8b06f
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  8c8b06f

  Copy full SHA for 8c8b06f

• Fix test send_recv_unbounded for arbitrarty BLOCK_CAP values

  Show description for dc81be3
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  dc81be3

  Copy full SHA for dc81be3

• Fix for rustfmt

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  8f5b00c

  Copy full SHA for 8f5b00c

• switch to break to exit loop

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  3c1dc33

  Copy full SHA for 3c1dc33

• resolve return value 0 for recv_many

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  757bc33

  Copy full SHA for 757bc33

• Change to recv_many to no longer clear the output buffer

  Show description for 0948857
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  0948857

  Copy full SHA for 0948857

• Filled buffer handling now fail-safe, not fail-fast

  Show description for 1dc2dbf
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  1dc2dbf

  Copy full SHA for 1dc2dbf

• improved doctest example

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  6bf430c

  Copy full SHA for 6bf430c

• fixed nested if; resolve documentation issues for recv_many

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  cdc3665

  Copy full SHA for cdc3665

• Update tokio/src/sync/mpsc/unbounded.rs

  Show description for 4c1321f
  

  aschweig

  and

  Darksonn

  committed
  4c1321f

  Copy full SHA for 4c1321f

• Update tokio/src/sync/mpsc/unbounded.rs

  Show description for 27ae226
  

  aschweig

  and

  Darksonn

  committed
  27ae226

  Copy full SHA for 27ae226

• Updated doctests to be similar; clarified documentation

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  9a1d9bc

  Copy full SHA for 9a1d9bc

• accomodate that with_capacity(n) gives capacity of at least n

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  7fca954

  Copy full SHA for 7fca954

• Improved documentation for recv_many and added test

  Show description for fe44b32
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  fe44b32

  Copy full SHA for fe44b32

• Update tokio/src/sync/mpsc/bounded.rs

  Show description for aac0eda
  

  aschweig

  and

  Darksonn

  committed
  aac0eda

  Copy full SHA for aac0eda

• Update tokio/src/sync/mpsc/bounded.rs

  Show description for 088537c
  

  aschweig

  and

  Darksonn

  committed
  088537c

  Copy full SHA for 088537c

• change recv_many doctests to use drop not scope

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  effb0e5

  Copy full SHA for effb0e5

• adopt improved wording on buffer capacity behavior

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  1fb08df

  Copy full SHA for 1fb08df

• Only reserve if no unused capacity and there is 1+ value(s) to receive

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  bd1ef3a

  Copy full SHA for bd1ef3a

• Updated recv_many to accept a new argument limit

  Show description for d31fd17
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  d31fd17

  Copy full SHA for d31fd17

• rename to_go to remaining

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  3cd2e46

  Copy full SHA for 3cd2e46

• Change behavior of recv_many(buf, 0) to return 0 immediately.

  Show description for 326fa53
  

  Aaron Schweiger

  authored and

  aschweig

  committed
  326fa53

  Copy full SHA for 326fa53

• Fix doc issues

  

  Aaron Schweiger

  authored and

  aschweig

  committed
  e8950ce

  Copy full SHA for e8950ce

Commits on Oct 11, 2023

• Update tokio/src/sync/mpsc/chan.rs

  Show description for ead4ca6
  

  aschweig

  and

  Darksonn

  authored
  ead4ca6

  Copy full SHA for ead4ca6

• Update tokio/src/sync/mpsc/chan.rs

  Show description for 2fcb715
  

  aschweig

  and

  Darksonn

  authored
  2fcb715

  Copy full SHA for 2fcb715

• check the coop budget in limit==0 case

  

  Aaron Schweiger

  authored and

  Aaron Schweiger

  committed
  ba46b7c

  Copy full SHA for ba46b7c

• clean up some recv_many tests

  

  Aaron Schweiger

  authored and

  Aaron Schweiger

  committed
  b1d1cae

  Copy full SHA for b1d1cae

• Update tokio/src/sync/mpsc/bounded.rs

  Show description for f162ca7
  

  aschweig

  and

  Darksonn

  authored
  f162ca7

  Copy full SHA for f162ca7

• Reflow doc comments; adjust comment in chan.rs

  

  Aaron Schweiger

  authored and

  Aaron Schweiger

  committed
  9f39dc7

  Copy full SHA for 9f39dc7

Commits on Oct 13, 2023

• Merge branch 'master' into recv_many

  Darksonn

  authored
  27e39d9

  Copy full SHA for 27e39d9