Upgrade to akka stream 1.0

build.sbt

@@ -1,7 +1,7 @@
 lazy val commonSettings = Seq(
   organization := "net.fehmicansaglam",
   version := "0.6-SNAPSHOT",
-  scalaVersion := "2.11.6",
+  scalaVersion := "2.11.7",
   scalacOptions := Seq(
     "-deprecation",
     "-encoding", "UTF-8", // yes, this is 2 args

examples/src/main/scala/net/fehmicansaglam/tepkin/examples/Example1.scala

@@ -1,6 +1,6 @@
 package net.fehmicansaglam.tepkin.examples
 
-import akka.stream.ActorFlowMaterializer
+import akka.stream.ActorMaterializer
 import akka.stream.scaladsl.Source
 import akka.util.Timeout
 import net.fehmicansaglam.bson.BsonDocument
@@ -31,7 +31,7 @@ object Example1 extends App {
   val collection2 = db("collection2")
 
   implicit val timeout: Timeout = 30.seconds
-  implicit val mat = ActorFlowMaterializer()
+  implicit val mat = ActorMaterializer()
 
   // Batch document source
   def documents(n: Int): Source[List[BsonDocument], Unit] = Source {

examples/src/main/scala/net/fehmicansaglam/tepkin/examples/SinkExample.scala

@@ -1,6 +1,6 @@
 package net.fehmicansaglam.tepkin.examples
 
-import akka.stream.ActorFlowMaterializer
+import akka.stream.ActorMaterializer
 import akka.stream.scaladsl.Source
 import net.fehmicansaglam.bson.BsonDsl._
 import net.fehmicansaglam.bson.{BsonDocument, Bulk}
@@ -23,7 +23,7 @@ object SinkExample extends App {
   // Obtain reference to the collection "collection2" using database
   val collection2 = db("collection2")
 
-  implicit val mat = ActorFlowMaterializer()
+  implicit val mat = ActorMaterializer()
 
   // Batch document source
   def documents(n: Int): Source[List[BsonDocument], Unit] = Source {

examples/src/main/scala/net/fehmicansaglam/tepkin/examples/TailableCursorExample.scala

@@ -1,6 +1,6 @@
 package net.fehmicansaglam.tepkin.examples
 
-import akka.stream.ActorFlowMaterializer
+import akka.stream.ActorMaterializer
 import akka.util.Timeout
 import net.fehmicansaglam.bson.BsonDocument
 import net.fehmicansaglam.tepkin.MongoClient
@@ -14,7 +14,7 @@ object TailableCursorExample extends App {
   import client.{context, ec}
 
   implicit val timeout: Timeout = 5.seconds
-  implicit val mat = ActorFlowMaterializer()
+  implicit val mat = ActorMaterializer()
 
   val db = client("tepkin")
   val messages = db("messages")

project/Dependencies.scala

@@ -1,5 +1,5 @@
 object Dependencies {
   val akkaV = "2.3.11"
-  val akkaStreamV = "1.0-RC3"
+  val akkaStreamV = "1.0"
   val scalatestV = "2.2.4"
 }

tepkin/src/main/scala/net/fehmicansaglam/tepkin/GridFs.scala

@@ -4,7 +4,7 @@ import java.io._
 import java.security.MessageDigest
 
 import akka.actor.ActorRef
-import akka.stream.FlowMaterializer
+import akka.stream.Materializer
 import akka.stream.io.SynchronousFileSource
 import akka.stream.scaladsl.Source
 import akka.util.{ByteString, Timeout}
@@ -33,7 +33,7 @@ class GridFs(db: MongoDatabase, prefix: String = "fs") {
   /**
    * Puts the given file into GridFS.
    */
-  def put(file: File)(implicit mat: FlowMaterializer, ec: ExecutionContext, timeout: Timeout): Future[BsonDocument] = {
+  def put(file: File)(implicit mat: Materializer, ec: ExecutionContext, timeout: Timeout): Future[BsonDocument] = {
     val fileId = BsonObjectId.generate
     val zero = (0, MessageDigest.getInstance("MD5"))
 

tepkin/src/test/scala/net/fehmicansaglam/tepkin/GridFsSpec.scala

@@ -3,7 +3,7 @@ package net.fehmicansaglam.tepkin
 import java.io.{File, FileInputStream}
 import java.security.MessageDigest
 
-import akka.stream.ActorFlowMaterializer
+import akka.stream.ActorMaterializer
 import akka.util.Timeout
 import net.fehmicansaglam.bson.BsonDsl._
 import net.fehmicansaglam.bson.Implicits._
@@ -28,8 +28,7 @@ class GridFsSpec
   val db = client("tepkin")
   val fs = db.gridFs()
 
-  import client.ec
-  import client.context
+  import client.{context, ec}
 
   implicit val timeout: Timeout = 30.seconds
 
@@ -47,7 +46,7 @@ class GridFsSpec
   override protected def afterAll() = client.shutdown()
 
   "A GridFs" should "put and find and delete File" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val result = for {
       put <- fs.put(new File(getClass.getResource("/sample.pdf").getPath))
@@ -63,7 +62,7 @@ class GridFsSpec
   }
 
   it should "put and get and delete File" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val result = for {
       put <- fs.put(new File(getClass.getResource("/sample.pdf").getPath))
@@ -84,7 +83,7 @@ class GridFsSpec
   }
 
   it should "put and get and delete FileInputStream" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val result = for {
       put <- fs.put("sample.pdf", new FileInputStream(getClass.getResource("/sample.pdf").getPath))

tepkin/src/test/scala/net/fehmicansaglam/tepkin/MongoCollectionSpec.scala

@@ -1,6 +1,6 @@
 package net.fehmicansaglam.tepkin
 
-import akka.stream.ActorFlowMaterializer
+import akka.stream.ActorMaterializer
 import akka.stream.scaladsl.Source
 import akka.util.Timeout
 import net.fehmicansaglam.bson.BsonDocument
@@ -61,7 +61,7 @@ class MongoCollectionSpec
   }
 
   it should "insert and find 10 documents" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val documents = (1 to 10).map(i => $document("name" := s"fehmi$i"))
 
@@ -78,7 +78,7 @@ class MongoCollectionSpec
   }
 
   it should "insert and find 1000 documents" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val documents = (1 to 1000).map(i => $document("name" := s"fehmi$i"))
 
@@ -95,7 +95,7 @@ class MongoCollectionSpec
   }
 
   it should "insert and find 100000 documents" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val documents: Source[List[BsonDocument], Unit] = Source {
       Iterable.tabulate(100) { _ =>
@@ -165,7 +165,7 @@ class MongoCollectionSpec
   }
 
   it should "group by and calculate a sum" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val documents: Seq[BsonDocument] = Seq(
       ("_id" := 1) ~ ("cust_id" := "abc1") ~ ("status" := "A") ~ ("amount" := 50),

tepkin/src/test/scala/net/fehmicansaglam/tepkin/MongoDatabaseSpec.scala

@@ -1,6 +1,6 @@
 package net.fehmicansaglam.tepkin
 
-import akka.stream.ActorFlowMaterializer
+import akka.stream.ActorMaterializer
 import akka.util.Timeout
 import net.fehmicansaglam.bson.BsonDocument
 import org.scalatest._
@@ -21,15 +21,14 @@ class MongoDatabaseSpec
   val client = MongoClient("mongodb://localhost")
   val db = client("tepkin")
 
-  import client.ec
-  import client.context
+  import client.{context, ec}
 
   implicit val timeout: Timeout = 30.seconds
 
   override protected def afterAll() = client.shutdown()
 
   "A MongoDatabase" should "list collections" in {
-    implicit val mat = ActorFlowMaterializer()
+    implicit val mat = ActorMaterializer()
 
     val result = for {
       source <- db.listCollections()