Code

Concurrent stream#164

Code

Merged

yoshuawuyts merged 49 commits intomainyoshuawuyts/futures-concurrency:mainfrom concurrent-streamyoshuawuyts/futures-concurrency:concurrent-streamCopy head branch name to clipboardMar 21, 2024

+1,760-22

Commits

Commits on Mar 20, 2024

• start implementing a concurrent for_each

  yoshuawuyts

  committed
  4fc3a9a

  Copy full SHA for 4fc3a9a

• Update mod.rs

  yoshuawuyts

  committed
  b15a413

  Copy full SHA for b15a413

• notes on ordering

  yoshuawuyts

  committed
  0531290

  Copy full SHA for 0531290

• allow concurrent stream to operate on an async closure

  yoshuawuyts

  committed
  ded646f

  Copy full SHA for ded646f

• add tests

  yoshuawuyts

  committed
  fa3d0f3

  Copy full SHA for fa3d0f3

• start defining the concurrent stream trait

  yoshuawuyts

  committed
  c47ba6d

  Copy full SHA for c47ba6d

• implement concurrent map

  yoshuawuyts

  committed
  addef7c

  Copy full SHA for addef7c

• don't clone atomics

  yoshuawuyts

  committed
  6599e1c

  Copy full SHA for 6599e1c

• Revert "don't clone atomics"

  Show description for d398d8a
  yoshuawuyts

  committed
  d398d8a

  Copy full SHA for d398d8a

• Revert "implement concurrent map"

  Show description for 1a7dda4
  yoshuawuyts

  committed
  1a7dda4

  Copy full SHA for 1a7dda4

• don't clone atomics

  yoshuawuyts

  committed
  07f82fc

  Copy full SHA for 07f82fc

• it works!

  yoshuawuyts

  committed
  7c380e2

  Copy full SHA for 7c380e2

• implement ConcurrentIterator::map

  yoshuawuyts

  committed
  a54f367

  Copy full SHA for a54f367

• implement most of foreach

  yoshuawuyts

  committed
  1fba7cc

  Copy full SHA for 1fba7cc

• use streamgroup in for_each

  yoshuawuyts

  committed
  d4457ef

  Copy full SHA for d4457ef

• update PassThrough

  yoshuawuyts

  committed
  faf5f26

  Copy full SHA for faf5f26

• make Future an associated type of ConcurrentStream

  yoshuawuyts

  committed
  c1535f3

  Copy full SHA for c1535f3

• update Drain

  yoshuawuyts

  committed
  cc5b97c

  Copy full SHA for cc5b97c

• update for_each

  yoshuawuyts

  committed
  4db355a

  Copy full SHA for 4db355a

• concurrent drain

  yoshuawuyts

  committed
  c958e5a

  Copy full SHA for c958e5a

• for_each works!

  yoshuawuyts

  committed
  6fab7af

  Copy full SHA for 6fab7af

• tweak examples

  yoshuawuyts

  committed
  fbea630

  Copy full SHA for fbea630

• concurrent driving of streams

  yoshuawuyts

  committed
  294942a

  Copy full SHA for 294942a

• split limit into its own method

  yoshuawuyts

  committed
  3deb039

  Copy full SHA for 3deb039

• boilerplate try_for_each

  yoshuawuyts

  committed
  ac0ac0d

  Copy full SHA for ac0ac0d

• correctly short-circuit

  yoshuawuyts

  committed
  4e2d283

  Copy full SHA for 4e2d283

• add ConcurrentStream::enumerate

  yoshuawuyts

  committed
  b85e222

  Copy full SHA for b85e222

• impl size_hint for ConcurrentStream

  yoshuawuyts

  committed
  e45af14

  Copy full SHA for e45af14

• remove passthrough and add struct docs

  yoshuawuyts

  committed
  ab7276b

  Copy full SHA for ab7276b

• move IntoConcurrentStream to a new location

  yoshuawuyts

  committed
  f22665d

  Copy full SHA for f22665d

• put ConcurrentStream behind the alloc feature

  yoshuawuyts

  committed
  433d67d

  Copy full SHA for 433d67d

• fix alloc and no_std builds

  yoshuawuyts

  committed
  d48d38a

  Copy full SHA for d48d38a

• implement collect

  yoshuawuyts

  committed
  52168e5

  Copy full SHA for 52168e5

• fix alloc builds

  yoshuawuyts

  committed
  5e4b495

  Copy full SHA for 5e4b495

• add private Try traits

  yoshuawuyts

  committed
  b8835d9

  Copy full SHA for b8835d9

• use the private Try trait for try_for_each

  yoshuawuyts

  committed
  a5a4022

  Copy full SHA for a5a4022

• fix core builds

  yoshuawuyts

  committed
  6fca1e7

  Copy full SHA for 6fca1e7

• add an IntoAsyncStream impl for Vec

  yoshuawuyts

  committed
  6918f71

  Copy full SHA for 6918f71

• remove drain

  yoshuawuyts

  committed
  4667657

  Copy full SHA for 4667657

• allow unused utils

  yoshuawuyts

  committed
  ce89592

  Copy full SHA for ce89592

• Delete drain.rs

  yoshuawuyts

  committed
  cf43c56

  Copy full SHA for cf43c56

• rename finish to flush

  yoshuawuyts

  committed
  49b91e9

  Copy full SHA for 49b91e9

• start pinning APIs

  yoshuawuyts

  committed
  745bb53

  Copy full SHA for 745bb53

• stack-pin the FutureGroup

  yoshuawuyts

  committed
  ac9087c

  Copy full SHA for ac9087c

• fix alloc feature

  yoshuawuyts

  committed
  8bed249

  Copy full SHA for 8bed249

• apply clippy fixes

  yoshuawuyts

  committed
  aab09ed

  Copy full SHA for aab09ed

• fix alloc warnings?

  yoshuawuyts

  committed
  bf9d34c

  Copy full SHA for bf9d34c

Commits on Mar 21, 2024

• remove redundant import of ConcurrentStream

  matheus-consoli

  committed
  f1a64d1

  Copy full SHA for f1a64d1

• remove more redundant imports

  matheus-consoli

  committed
  8ef8cd0

  Copy full SHA for 8ef8cd0