Skip to content

Commit

Permalink
Remove test warnings
Browse files Browse the repository at this point in the history
  • Loading branch information
knutwalker committed Apr 4, 2018
1 parent 0222f20 commit 1795d54
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,17 +18,15 @@ package scalax.transducers.contrib

import scalax.transducers.ContribTransducer

import akka.NotUsed
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{ Keep, Flow, Sink, Source }
import akka.stream.javadsl.{ Keep JKeep, Flow JFlow, Sink JSink, Source JSource }

import org.specs2.concurrent.ExecutionEnv
import org.specs2.mutable.Specification
import org.specs2.specification.AfterAll

import scala.concurrent.{ Future, Await }
import scala.concurrent.Await
import scala.concurrent.duration._


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,7 @@
package scalax
package transducers.internal

import scalaz.{NonEmptyList, Tag, @@}

import org.scalacheck.{Gen, Arbitrary}
import org.scalacheck.Arbitrary.arbitrary
import org.scalacheck.Arbitrary

import transducers.Transducer

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,10 @@ object TransducersSpec extends Specification with ScalaCheck with Arbitraries wi

"run a side-effect for each value" in prop { (xs: List[Int])
val sideEffects = new AtomicInteger
val tx_! = transducers.foreach[Int](_ sideEffects.incrementAndGet())
val tx_! = transducers.foreach[Int](_ {
sideEffects.incrementAndGet()
()
})
run(xs, tx_!)
sideEffects.get ==== xs.length
}
Expand Down

0 comments on commit 1795d54

Please sign in to comment.