Remove unnecessary call

danslapman · danslapman · commit 0af886e4ce1d · 2017-10-22T16:25:35.000+03:00
diff --git a/src/main/scala/asyncstreams/ASMonadPlusForMonadError.scala b/src/main/scala/asyncstreams/ASMonadPlusForMonadError.scala
@@ -9,7 +9,6 @@ import scalaz.{MonadError, MonadPlus}
 class ASMonadPlusForMonadError[F[+_]](implicit fmp: MonadError[F, Throwable], zk: ZeroK[F]) extends MonadPlus[AsyncStream[F, ?]] {
   override def bind[A, B](fa: AsyncStream[F, A])(f: (A) => AsyncStream[F, B]): AsyncStream[F, B] = AsyncStream {
     fa.data.flatMap(step => f(step.value).data.map(step2 => Step(step2.value, plus(step2.rest, bind(step.rest)(f)))))
-    .handleError(_ => zk.zero)
   }
 
   override def plus[A](a: AsyncStream[F, A], b: => AsyncStream[F, A]): AsyncStream[F, A] = AsyncStream {

Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,6 @@ import scalaz.{MonadError, MonadPlus}`
`9`	`9`	`class ASMonadPlusForMonadError[F[+_]](implicit fmp: MonadError[F, Throwable], zk: ZeroK[F]) extends MonadPlus[AsyncStream[F, ?]] {`
`10`	`10`	`override def bind[A, B](fa: AsyncStream[F, A])(f: (A) => AsyncStream[F, B]): AsyncStream[F, B] = AsyncStream {`
`11`	`11`	`fa.data.flatMap(step => f(step.value).data.map(step2 => Step(step2.value, plus(step2.rest, bind(step.rest)(f)))))`
`12`		`- .handleError(_ => zk.zero)`
`13`	`12`	`}`
`14`	`13`
`15`	`14`	`override def plus[A](a: AsyncStream[F, A], b: => AsyncStream[F, A]): AsyncStream[F, A] = AsyncStream {`