File tree Expand file tree Collapse file tree 2 files changed +6
-5
lines changed
Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -47,10 +47,10 @@ def dep(org: String)(version: String)(modules: String*) =
4747
4848lazy val dependencies =
4949 libraryDependencies ++= Seq (
50- " co.fs2" %% " fs2-core" % " 1.0.0-M4 " ,
51- " org.typelevel" %% " cats-core" % " 1.2 .0" ,
50+ " co.fs2" %% " fs2-core" % " 1.0.0" ,
51+ " org.typelevel" %% " cats-core" % " 1.4 .0" ,
5252 " org.typelevel" %% " dogs-core" % " 0.6.10" ,
53- " org.typelevel" %% " cats-effect" % " 1.0.0-RC3 "
53+ " org.typelevel" %% " cats-effect" % " 1.0.0"
5454 )
5555
5656lazy val tests = {
Original file line number Diff line number Diff line change 11package upperbound
22
33import cats .Applicative
4- import fs2 .{Pipe , Stream , async }
4+ import fs2 .{Pipe , Stream }
5+ import fs2 .concurrent .SignallingRef
56import cats .effect .{Concurrent , Timer }
67import cats .effect .concurrent .{Deferred , Ref }
78import cats .syntax .functor ._
@@ -167,7 +168,7 @@ object core {
167168 n : Int )(implicit Timer : Timer [F ],
168169 Concurrent : Concurrent [F ]): F [Limiter [F ]] =
169170 Queue .bounded[F , F [BackPressure ]](n) flatMap { queue =>
170- async.signalOf [F , Boolean ](false ) flatMap { stop =>
171+ SignallingRef [F , Boolean ](false ) flatMap { stop =>
171172 Ref .of[F , FiniteDuration ](period) flatMap { interval =>
172173 // `job` needs to be executed asynchronously so that long
173174 // running jobs don't interfere with the frequency of pulling
You can’t perform that action at this time.
0 commit comments