Permalink
Browse files

Fixed build

  • Loading branch information...
mpilquist committed Dec 4, 2017
1 parent 601b8d2 commit 640061428d17ef205b6995d5b6c501a19eae67c1
@@ -11,7 +11,7 @@ class ConcurrentBenchmark {
@GenerateN(1, 2, 4, 7, 16, 32, 64, 128, 256)
@Benchmark
def join(N: Int): Int = {
val each = Stream.segment(Chunk.seq(0 to 1000).map(i => Stream.eval(IO.pure(i)))).covary[IO]
val each = Stream.segment(Segment.seq(0 to 1000).map(i => Stream.eval(IO.pure(i)))).covary[IO]
each.join(N).runLast.unsafeRunSync.get
}
}
@@ -15,7 +15,7 @@ final class ByteVectorChunk private (val toByteVector: ByteVector) extends Chunk
(ByteVectorChunk(before), ByteVectorChunk(after))
}
protected def mapStrict[O2](f: Byte => O2): Chunk[O2] =
override def map[O2](f: Byte => O2): Chunk[O2] =
Chunk.indexedSeq(toByteVector.toIndexedSeq.map(f))
}

0 comments on commit 6400614

Please sign in to comment.