Code

New topic#2252

Code

Merged

SystemFw merged 27 commits intotypelevel:maintypelevel/fs2:mainfrom SystemFw:new-topicSystemFw/fs2:new-topicCopy head branch name to clipboardFeb 8, 2021

+112-167

Commits

Commits on Feb 6, 2021

• Get old Topic implementation compiling again

  SystemFw

  committed
  b625b88

  Copy full SHA for b625b88

• Replace bespoke ID with Unique in new Topic implementation

  SystemFw

  committed
  bd0359e

  Copy full SHA for bd0359e

• Replace signal retry loop in Topic with normal enqueue

  SystemFw

  committed
  7f0d0f2

  Copy full SHA for 7f0d0f2

• Swap new implementation of Topic

  SystemFw

  committed
  18fc165

  Copy full SHA for 18fc165

• Rename signal used to track the number of Topic subscriber

  SystemFw

  committed
  b894f19

  Copy full SHA for b894f19

• Replace Vector + Unique with LongMap in Topic

  SystemFw

  committed
  ebc0f56

  Copy full SHA for ebc0f56

• Remove unnecessary state in Topic

  SystemFw

  committed
  4a5f22e

  Copy full SHA for 4a5f22e

• Topic subscriber is a Resource

  SystemFw

  committed
  768c066

  Copy full SHA for 768c066

• Remove Topic.subscribeSize

  SystemFw

  committed
  f567434

  Copy full SHA for f567434

• Remove no longer relevant scaladoc

  SystemFw

  committed
  9bab3a3

  Copy full SHA for 9bab3a3

• Do not retain latest element in Topic

  SystemFw

  committed
  8b42c50

  Copy full SHA for 8b42c50

• Adapt Topic test to new semantics: no elements retained

  SystemFw

  committed
  c1957f6

  Copy full SHA for c1957f6

• Remove subscriber

  SystemFw

  committed
  c0ad860

  Copy full SHA for c0ad860

• Remove old Topic

  SystemFw

  committed
  0075b59

  Copy full SHA for 0075b59

• Use cats.effect Queue inside Topic

  SystemFw

  committed
  97a2a3c

  Copy full SHA for 97a2a3c

• Simplify Topic implementation

  SystemFw

  committed
  31b5f20

  Copy full SHA for 31b5f20

• Add subscribeAwait to Topic

  SystemFw

  committed
  097ffd1

  Copy full SHA for 097ffd1

• Test awaiting for subscriptions on Topic

  SystemFw

  committed
  481e8e9

  Copy full SHA for 481e8e9

• Formatting

  SystemFw

  committed
  d7cf861

  Copy full SHA for d7cf861

• Remove unused import

  SystemFw

  committed
  e7313cb

  Copy full SHA for e7313cb

• Try to shadow fs2 Queue

  SystemFw

  committed
  c7b0a84

  Copy full SHA for c7b0a84

• Rename c.e.Queue to avoid any clashes

  SystemFw

  committed
  9048816

  Copy full SHA for 9048816

• Fix memory leak spec compilation for Topic

  SystemFw

  committed
  f809f86

  Copy full SHA for f809f86

• Get Topic docs to compile

  SystemFw

  committed
  8a92792

  Copy full SHA for 8a92792

Commits on Feb 8, 2021

• Topic scaladoc fixes

  SystemFw

  committed
  d034eb8

  Copy full SHA for d034eb8

• Use evalMap in Topic.publish

  SystemFw

  committed
  4a33775

  Copy full SHA for 4a33775

• Standardise Topic.publish with other sinks

  SystemFw

  committed
  de79ebf

  Copy full SHA for de79ebf