Code

Add List[Stream]#parJoinUnbounded.#3363

Code

Merged

mpilquist merged 11 commits intotypelevel:maintypelevel/fs2:mainfrom kamilkloch:list-parjoinkamilkloch/fs2:list-parjoinCopy head branch name to clipboardJan 20, 2024

+414-6

Commits

Commits on Dec 14, 2023

• Add List[Stream]#parJoinUnbounded. WIP.

  

  Kamil Kloch

  committed
  86e3e99

  Copy full SHA for 86e3e99

Commits on Dec 17, 2023

• Properly handle short-circuiting.

  kamilkloch

  committed
  009dce8

  Copy full SHA for 009dce8

• Cosmetics.

  kamilkloch

  committed
  367e0dd

  Copy full SHA for 367e0dd

• Update tests.

  kamilkloch

  committed
  712eb14

  Copy full SHA for 712eb14

• Fix compilation error.

  kamilkloch

  committed
  cb09e54

  Copy full SHA for cb09e54

• Add comment.

  kamilkloch

  committed
  98578b6

  Copy full SHA for 98578b6

Commits on Dec 18, 2023

• Update core/shared/src/main/scala/fs2/Stream.scala

  Show description for f00139f
  

  kamilkloch

  and

  armanbilge

  authored
  f00139f

  Copy full SHA for f00139f

• Simplifiy implementation.

  kamilkloch

  committed
  5895f3f

  Copy full SHA for 5895f3f

• Fix compilation error.

  kamilkloch

  committed
  5f6b674

  Copy full SHA for 5f6b674

• Switch to Channel.synchronous.

  kamilkloch

  committed
  198f7c6

  Copy full SHA for 198f7c6

• Update tests.

  kamilkloch

  committed
  f6702f0

  Copy full SHA for f6702f0