From dcfd13b52b7ebb27a099612b2c844a1a3653eca6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jakub=20Koz=C5=82owski?= Date: Thu, 6 Sep 2018 17:03:49 +0200 Subject: [PATCH] Use context bound --- src/main/scala/io/circe/fs2/package.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/scala/io/circe/fs2/package.scala b/src/main/scala/io/circe/fs2/package.scala index 98546e4..3446da3 100644 --- a/src/main/scala/io/circe/fs2/package.scala +++ b/src/main/scala/io/circe/fs2/package.scala @@ -17,8 +17,8 @@ package object fs2 { final def byteStreamParserC[F[_] : RaiseThrowable]: Pipe[F, Chunk[Byte], Json] = byteParserC(AsyncParser.ValueStream) - final def stringParser[F[_]](mode: AsyncParser.Mode)(implicit F: RaiseThrowable[F]): Pipe[F, String, Json] = new ParsingPipe[F, String] { - override protected[this] val raiseThrowable: RaiseThrowable[F] = F + final def stringParser[F[_] : RaiseThrowable](mode: AsyncParser.Mode): Pipe[F, String, Json] = new ParsingPipe[F, String] { + override protected[this] val raiseThrowable: RaiseThrowable[F] = implicitly[RaiseThrowable[F]] protected[this] final def parseWith(p: AsyncParser[Json])(in: String): Either[ParseException, Seq[Json]] = p.absorb(in)(CirceSupportParser.facade) @@ -26,9 +26,9 @@ package object fs2 { protected[this] val parsingMode: AsyncParser.Mode = mode } - final def byteParserC[F[_]](mode: AsyncParser.Mode)(implicit F: RaiseThrowable[F]): Pipe[F, Chunk[Byte], Json] = + final def byteParserC[F[_] : RaiseThrowable](mode: AsyncParser.Mode): Pipe[F, Chunk[Byte], Json] = new ParsingPipe[F, Chunk[Byte]] { - override protected[this] val raiseThrowable: RaiseThrowable[F] = F + override protected[this] val raiseThrowable: RaiseThrowable[F] = implicitly[RaiseThrowable[F]] protected[this] final def parseWith(p: AsyncParser[Json])(in: Chunk[Byte]): Either[ParseException, Seq[Json]] = p.absorb(in.toArray)(CirceSupportParser.facade)