-
Notifications
You must be signed in to change notification settings - Fork 12
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Upgrade to fs2-1.0.0-M1 #50
Conversation
Codecov Report
@@ Coverage Diff @@
## master #50 +/- ##
=======================================
Coverage 93.58% 93.58%
=======================================
Files 4 4
Lines 78 78
Branches 2 2
=======================================
Hits 73 73
Misses 5 5
Continue to review full report at Codecov.
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks! 👍 I'll release this asap
@@ -3,7 +3,7 @@ import ReleaseTransformations._ | |||
|
|||
lazy val buildSettings = Seq( | |||
organization := "com.github.zainab-ali", | |||
crossScalaVersions := List("2.12.4", "2.11.12"), | |||
crossScalaVersions := List("2.12.6", "2.11.12"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks!
final class StreamSubscriber[F[_], A](val sub: StreamSubscriber.FSM[F, A])(implicit A: Effect[F], | ||
ec: ExecutionContext) | ||
final class StreamSubscriber[F[_], A](val sub: StreamSubscriber.FSM[F, A])(implicit F: ConcurrentEffect[F], | ||
timer: Timer[F]) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I was a bit confused as to why ConcurrentEffect
was here when we're not using any of its methods. I see now that sub
requires a Concurrent
instance which is supplied on creation, so I suppose the subscriber could explicitly require a ConcurrentEffect
to indicate concurrency.
@@ -1 +1 @@ | |||
sbt.version=1.0.4 | |||
sbt.version=1.1.6 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks!
ExecutionContext
is replaced byTimer
Effect
is still necessary forunsafeRunAsync
s.Concurrent
is necessary forDeferred
, which replacesPromise
.Effect
+Concurrent
=ConcurrentEffect
Maybe we can whittle this down some more, but this is a minimal update that passes all tests.