Skip to content

Commit 689cf29

Browse files
authored
Merge pull request #663 from mpilquist/topic/move-task
Moved fs2.util.Task to fs2.Task and deleted the old, unfinished fs2.task object
2 parents 239a938 + 09ec061 commit 689cf29

31 files changed

+489
-575
lines changed

README.md

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,7 @@ Quick links: [About the library](#about), [Docs and getting help](#docs), [How t
1111
FS2 is a streaming I/O library. The design goals are compositionality, expressiveness, resource safety, and speed. Here's a simple example of its use:
1212

1313
``` scala
14-
import fs2.{io, text}
15-
import fs2.util.Task
14+
import fs2.{io, text, Task}
1615
import java.nio.file.Paths
1716

1817
def fahrenheitToCelsius(f: Double): Double =

benchmark/src/main/scala/fs2/benchmark/ConcurrentBenchmark.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
package fs2
22
package benchmark
33

4-
import fs2.util._
5-
64
import org.openjdk.jmh.annotations.{Benchmark, State, Scope}
75

86
@State(Scope.Thread)

benchmark/src/main/scala/fs2/benchmark/StreamBenchmark.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
package fs2
22
package benchmark
33

4-
import fs2.util._
5-
64
import org.openjdk.jmh.annotations.{Benchmark, State, Scope}
75

86
@State(Scope.Thread)

benchmark/src/main/scala/fs2/benchmark/TaskBenchmark.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
package fs2
22
package benchmark
33

4-
import fs2.util._
5-
64
import org.openjdk.jmh.annotations.{Benchmark, State, Scope}
75

86

@@ -19,7 +17,7 @@ class TaskBenchmark extends BenchmarkUtils {
1917
while(i < end) {
2018
i += 1
2119
sum += i
22-
}
20+
}
2321
sum
2422
}
2523

core/src/main/scala/fs2/Async.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package fs2
33
import Async.{Change,Future}
44
import fs2.util.{Free,Functor,Effect}
55

6-
@annotation.implicitNotFound("No implicit `Async[${F}]` found.\nNote that the implicit `Async[fs2.util.Task]` requires an implicit `fs2.Strategy` in scope.")
6+
@annotation.implicitNotFound("No implicit `Async[${F}]` found.\nNote that the implicit `Async[fs2.Task]` requires an implicit `fs2.Strategy` in scope.")
77
trait Async[F[_]] extends Effect[F] { self =>
88
type Ref[A]
99

core/src/main/scala/fs2/StreamDerived.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package fs2
22

3-
import fs2.util.{Catchable,RealSupertype,Sub1,Task}
3+
import fs2.util.{Catchable,RealSupertype,Sub1}
44

55
/** Various derived operations that are mixed into the `Stream` companion object. */
66
private[fs2]

0 commit comments

Comments
 (0)