Code

Broadcast#2312

Code

Merged

mpilquist merged 34 commits intotypelevel:maintypelevel/fs2:mainfrom SystemFw:broadcastSystemFw/fs2:broadcastCopy head branch name to clipboardMar 2, 2021

+92-280

Commits

Commits on Mar 2, 2021

• Example of scoping subscriptions properly

  SystemFw

  committed
  6e5e994

  Copy full SHA for 6e5e994

• Add more concise alternative for subscriber resource pattern

  SystemFw

  committed
  f41270b

  Copy full SHA for f41270b

• Scoping only solution to awaiting subscribers invalidated

  SystemFw

  committed
  5ab0586

  Copy full SHA for 5ab0586

• Add solution with better characteristics wrt to internal interruption

  SystemFw

  committed
  d9e7de9

  Copy full SHA for d9e7de9

• Move to Stream for the subscription logic

  SystemFw

  committed
  f4db84c

  Copy full SHA for f4db84c

• A more complex stream completely breaks scoping

  SystemFw

  committed
  a609807

  Copy full SHA for a609807

• Interruption case is covered by the proposed solution

  SystemFw

  committed
  aeba528

  Copy full SHA for aeba528

• Add Barrier based solution to broadcasting problem

  SystemFw

  committed
  46bb50f

  Copy full SHA for 46bb50f

• Isolate bug with Stream.resource

  SystemFw

  committed
  34d52c3

  Copy full SHA for 34d52c3

• Add provisional implementation of broadcastThrough with Topic

  SystemFw

  committed
  ea61eff

  Copy full SHA for ea61eff

• Revert "Add provisional implementation of broadcastThrough with Topic"

  Show description for 4b6c3a8
  SystemFw

  committed
  4b6c3a8

  Copy full SHA for 4b6c3a8

• Organise example file

  SystemFw

  committed
  b8c21a4

  Copy full SHA for b8c21a4

• Working prototype of broadcastThrough with Topic

  SystemFw

  committed
  48ece04

  Copy full SHA for 48ece04

• Sketch of Scope bug

  SystemFw

  committed
  4ba81fd

  Copy full SHA for 4ba81fd

• Easier encoding of interruptible resource trick

  SystemFw

  committed
  8aa5efb

  Copy full SHA for 8aa5efb

• Remove broadcastTo overload that just replicates data

  SystemFw

  committed
  3b55a0e

  Copy full SHA for 3b55a0e

• Remove the broadcastThrough overload that just replicates data

  SystemFw

  committed
  4d3484a

  Copy full SHA for 4d3484a

• Remove broadcastTo, it's not redundant given the shape of Sinks

  SystemFw

  committed
  050a5e5

  Copy full SHA for 050a5e5

• Rework scaladoc of broadcastThrough

  SystemFw

  committed
  1910964

  Copy full SHA for 1910964

• Remove some noise from experimentation playground

  SystemFw

  committed
  1fbac85

  Copy full SHA for 1fbac85

• Add example of deadlock upon pipe cancelation

  Show description for dc3c966
  SystemFw

  committed
  dc3c966

  Copy full SHA for dc3c966

• Add new implementation of broadcastThrough

  Show description for dbc7c26
  SystemFw

  committed
  dbc7c26

  Copy full SHA for dbc7c26

• Remove evidence of bug with Stream.resource, already handled

  SystemFw

  committed
  b06a3d3

  Copy full SHA for b06a3d3

• Add example of interruption bug with Topic

  SystemFw

  committed
  08fe32a

  Copy full SHA for 08fe32a

• Fix Topic bug that leads to deadlock after subscriber unpublishes

  SystemFw

  committed
  77c9fab

  Copy full SHA for 77c9fab

• broadcastThrough is now safe when a pipe interrupts

  SystemFw

  committed
  3108a9e

  Copy full SHA for 3108a9e

• Remove Pipe.join

  SystemFw

  committed
  b8707eb

  Copy full SHA for b8707eb

• remove broadcast

  SystemFw

  committed
  e86ad5d

  Copy full SHA for e86ad5d

• Remove Broadcast

  SystemFw

  committed
  2dee97f

  Copy full SHA for 2dee97f

• Delete playground

  SystemFw

  committed
  3d9a7ac

  Copy full SHA for 3d9a7ac

• Formatting

  SystemFw

  committed
  bbf6e1c

  Copy full SHA for bbf6e1c

• Fix compilation on 2.12

  SystemFw

  committed
  1d1b250

  Copy full SHA for 1d1b250

• Factor out some definitions in broadcast

  SystemFw

  committed
  b7646ad

  Copy full SHA for b7646ad

• Cleanup of drained queue in topic

  SystemFw

  committed
  3f15c78

  Copy full SHA for 3f15c78