Get rid of .impl._ import

Author: danslapman

build.sbt

@@ -2,7 +2,7 @@ name := "asyncstreams"
 
 organization := "danslapman"
 
-version := "0.6-SNAPSHOT"
+version := "1.0-rc1"
 
 scalaVersion := "2.12.4"
 

readme.md

@@ -23,20 +23,12 @@ asyncstreams is tested to work with:
 - twitter futures
 - monix tasks
 
-Currently, asyncstreams' main branch uses scalaz's typeclasses. If Your projects uses cats
-or have some other cats-based dependencies, You can use cats-based port, which have feature parity
-with master, but is experimental for now. I'm planning to migrate master to cats after cats 1.0.0 is released.
-
 asyncstreams is available via bintray:
 
 ```
     resolvers += Resolver.bintrayRepo("danslapman", "maven")
 
-    //scalaz-based
-    libraryDependencies += "danslapman" %% "asyncstreams" % "0.5"
-    
-    //cats-based
-    libraryDependencies += "danslapman" %% "asyncstreams" % "0.5-cats-rc1"
+    libraryDependencies += "danslapman" %% "asyncstreams" % "1.0-rc1"
 ```
 
 asyncstreams initially based on [scala-async](https://github.com/iboltaev/scala-async) ideas.

src/main/scala/asyncstreams/impl/package.scala

@@ -1,4 +1,5 @@
-import cats.Monad
+import alleycats.EmptyK
+import cats.{Alternative, Monad, MonadError}
 import cats.mtl.FunctorEmpty
 import cats.mtl.syntax.empty._
 import cats.syntax.applicative._
@@ -17,4 +18,10 @@ package object asyncstreams {
   implicit class FunctorWithFilter[F[_] : FunctorEmpty, A](fa: F[A]) {
     def withFilter(f: A => Boolean): F[A] = fa.filter(f)
   }
+
+  implicit def streamInstance[F[+_]: λ[`x[+_]` => MonadError[x, Throwable]]]: Monad[AsyncStream[F, +?]] with Alternative[AsyncStream[F, +?]] = new ASInstanceForMonadError[F]
+  implicit def asimpl[F[+_]: λ[`x[+_]` => MonadError[x, Throwable]]]: ASImpl[F] = new ASImplForMonadError[F]
+  implicit def zeroK[F[+_]](implicit me: MonadError[F, Throwable]): EmptyK[F] = new EmptyK[F] {
+    override def empty[A]: F[A] = me.raiseError(new NoSuchElementException)
+  }
 }

src/main/scala/asyncstreams/package.scala

@@ -1,7 +1,6 @@
 package asyncstreams.monixTask
 
 import asyncstreams._
-import asyncstreams.impl._
 import cats.syntax.applicative._
 import cats.syntax.flatMap._
 import cats.syntax.functor._

src/test/scala/asyncstreams/monixTask/AsyncStreamTestsWithMonixTask.scala

@@ -1,7 +1,6 @@
 package asyncstreams.stdFuture
 
 import asyncstreams._
-import asyncstreams.impl._
 import asyncstreams.statet._
 import cats.instances.future._
 import cats.mtl.instances.state._

src/test/scala/asyncstreams/stdFuture/AsyncStreamMonadSyntaxTests.scala

@@ -1,7 +1,6 @@
 package asyncstreams.stdFuture
 
 import asyncstreams._
-import asyncstreams.impl._
 import cats.instances.int._
 import cats.instances.future._
 import cats.syntax.applicative._

src/test/scala/asyncstreams/stdFuture/AsyncStreamOperations.scala

@@ -3,7 +3,6 @@ package asyncstreams.stdFuture
 import java.util.concurrent.Executors
 
 import asyncstreams._
-import asyncstreams.impl._
 import asyncstreams.{ASImpl, AsyncStream}
 import cats.Monad
 import cats.instances.future._

src/test/scala/asyncstreams/stdFuture/AsyncStreamTestsWithStandardFuture.scala

@@ -1,7 +1,6 @@
 package asyncstreams.stdFuture
 
 import asyncstreams._
-import asyncstreams.impl._
 import cats.instances.future._
 import org.scalatest.{FunSuite, Matchers}
 

src/test/scala/asyncstreams/stdFuture/AsyncStreamUtilityMethodTests.scala

@@ -1,7 +1,6 @@
 package asyncstreams.twitterFuture
 
 import asyncstreams._
-import asyncstreams.impl._
 import asyncstreams.{ASImpl, AsyncStream}
 import cats.syntax.flatMap._
 import cats.syntax.functor._