Code

WIP: Add Flow interop#3901

Code

Draft

BalmungSan wants to merge 17 commits intotypelevel:series/3.xtypelevel/cats-effect:series/3.xfrom BalmungSan:flow-interopBalmungSan/cats-effect:flow-interopCopy head branch name to clipboard

+864

Commits

Commits on Nov 22, 2023

• Add AsyncSubscriber

  BalmungSan

  committed
  e6b3324

  Copy full SHA for e6b3324

• Add std.flow package

  BalmungSan

  committed
  29d7a10

  Copy full SHA for 29d7a10

• Add the fundamental std.flow.fromPublisher function

  BalmungSan

  committed
  1d836df

  Copy full SHA for 1d836df

• Properly implement AsyncSubscriber

  BalmungSan

  committed
  011a7b4

  Copy full SHA for 011a7b4

• Add the simplified std.flow.fromPublisher function

  BalmungSan

  committed
  5653cff

  Copy full SHA for 5653cff

• Add the Publisher.toEffect extension method to std.flow.syntax

  BalmungSan

  committed
  43fd5cb

  Copy full SHA for 43fd5cb

Commits on Nov 23, 2023

• Add AsyncSubscription

  BalmungSan

  committed
  37b9d8e

  Copy full SHA for 37b9d8e

• Add AsyncPublisher

  BalmungSan

  committed
  e58025e

  Copy full SHA for e58025e

• Add std.flow.toPublisher and subscribeEffect functions

  BalmungSan

  committed
  70aff93

  Copy full SHA for 70aff93

• Add the fa.toPublisher and fa.subscribe extension methods to std.flow.syntax

  BalmungSan

  committed
  def8f34

  Copy full SHA for def8f34

• Move flow interop to core

  BalmungSan

  committed
  168130f

  Copy full SHA for 168130f

• Add AsyncPublisher.unsafe

  BalmungSan

  committed
  b7f0753

  Copy full SHA for b7f0753

• Add the cats.effect.interop.flow.unsafeToPublisher function

  BalmungSan

  committed
  d3d0e36

  Copy full SHA for d3d0e36

• Add io.unsafeToPublisher() extension method to interop.flow.syntax

  BalmungSan

  committed
  eb9a0ed

  Copy full SHA for eb9a0ed

• Add license header to AsyncSubscription.scala

  BalmungSan

  committed
  8e81c9a

  Copy full SHA for 8e81c9a

Commits on Nov 24, 2023

• Make AsyncSubscription.run a def

  BalmungSan

  committed
  f6e6f0a

  Copy full SHA for f6e6f0a

• Wait for Dispatcher in AsyncPublisher

  BalmungSan

  committed
  270cc6d

  Copy full SHA for 270cc6d