fixed scala-2.12 deprecations

Author: rssh

build.sbt

@@ -3,8 +3,7 @@ name:="scala-gopher"
 
 organization:="com.github.rssh"
 
-//scalaVersion := "2.12.0"
-scalaVersion := "2.12.1-SNAPSHOT"
+scalaVersion := "2.12.0"
 
 resolvers += Resolver.sonatypeRepo("snapshots")
 
@@ -17,7 +16,7 @@ scalacOptions ++= Seq("-unchecked","-deprecation", "-feature"
 
 libraryDependencies <+= scalaVersion( "org.scala-lang" % "scala-reflect" % _ )
 
-libraryDependencies += "org.scala-lang.modules" %% "scala-async" % "0.9.7-SNAPSHOT-p1"
+libraryDependencies += "org.scala-lang.modules" %% "scala-async" % "0.9.6"
 //libraryDependencies += "org.scala-lang.modules" %% "scala-async" % "0.9.6-SNAPSHOT"
 
 libraryDependencies += "org.scalatest" %% "scalatest" % "3.0.0" % "test"

src/main/scala/gopher/channels/DuppedInput.scala

@@ -28,7 +28,7 @@ class DuppedInput[A](origin:Input[A])
         await(f2)
         ();
     }(ec) )
-  selector.go.onFailure{
+  selector.go.failed.foreach{
     case ex: ChannelClosedException =>
                    sink1.close()
                    sink2.close()

src/test/scala/gopher/channels/DuppedChannelsSuite.scala

@@ -13,7 +13,7 @@ import org.scalatest.concurrent._
 
 import scala.concurrent.ExecutionContext.Implicits.global
 
-class DuppedChannelsSuite extends FunSuite with AsyncAssertions {
+class DuppedChannelsSuite extends FunSuite with Waiters {
 
 
   test("duped input must show two") {
@@ -60,7 +60,7 @@ class DuppedChannelsSuite extends FunSuite with AsyncAssertions {
       in1.aread map { x =>  w(assert(x==1)); w.dismiss() } onComplete {
                            case Failure(ex) => w( throw ex )
                            case Success(_) =>
-                                     in1.aread onFailure{  case ex => w(assert(ex.isInstanceOf[ChannelClosedException]));
+                                     in1.aread.failed.foreach{ ex => w(assert(ex.isInstanceOf[ChannelClosedException]));
                                                            w.dismiss() 
                                  }
       }

src/test/scala/gopher/channels/FoldSelectSuite.scala

@@ -33,9 +33,7 @@ class FoldSelectSuite extends FunSuite
         }
       }
     }
-    generator.onFailure{
-      case ex: Throwable => ex.printStackTrace()
-    }
+    generator.failed.foreach{ _.printStackTrace() }
     in.awriteAll(2 to 100)
     //in.awriteAllDebug(2 to 100)
     val read = go {

src/test/scala/gopher/channels/IOTimeoutsSuite.scala

@@ -16,7 +16,7 @@ import scala.concurrent._
 import scala.concurrent.duration._
 import scala.concurrent.ExecutionContext.Implicits.global
 
-class IOTimeoutsSuite extends FunSuite with AsyncAssertions {
+class IOTimeoutsSuite extends FunSuite with Waiters {
 
 
   test("messsaged from timeouts must be appear during reading attempt from empty channel") {

src/test/scala/gopher/channels/InputOpsSuite.scala

@@ -13,7 +13,7 @@ import org.scalatest.concurrent._
 
 import scala.concurrent.ExecutionContext.Implicits.global
 
-class InputOpsSuite extends FunSuite with AsyncAssertions {
+class InputOpsSuite extends FunSuite with Waiters {
 
 
   test("map operation for input") {

src/test/scala/gopher/channels/UnbufferedSelectSuite.scala

@@ -12,7 +12,7 @@ import scala.concurrent.duration._
 import org.scalatest._
 import org.scalatest.concurrent._
 
-class UnbufferedSelectSuite extends FunSuite with AsyncAssertions
+class UnbufferedSelectSuite extends FunSuite with Waiters
 {
 
    import scala.concurrent.ExecutionContext.Implicits.global