How do I use “writeOutputStream” with an fs2 Stream[IO, Byte]
.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;
I am trying to use fs2.io.writeOutputStream for the output to a Java AWS lambda fn. I don't know how to provide the implicit parameter it's looking for:
"no implicits found for parameter cs: ContextShift[IO]"
I found some documentation for creating my own implicit ContextShift object but that seems like overkill for what I'm trying to do.
final def handleRequest(in: InputStream, out: OutputStream, context: Context): Unit = (for
bytes <- in.compile.toList
str = getString(bytes)
args <- decode(str).raiseIO
_ <- produce(args).to(writeOutputStream(IO(out), global)).compile.drain
yield Unit).unsafeRunAsyncAndForget() // throws exception in the case of Failure
// ------------------------------------------------
// produce(args: MyCaseClass): fs2.Stream[IO, Byte]
scala aws-lambda fs2
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
add a comment |
I am trying to use fs2.io.writeOutputStream for the output to a Java AWS lambda fn. I don't know how to provide the implicit parameter it's looking for:
"no implicits found for parameter cs: ContextShift[IO]"
I found some documentation for creating my own implicit ContextShift object but that seems like overkill for what I'm trying to do.
final def handleRequest(in: InputStream, out: OutputStream, context: Context): Unit = (for
bytes <- in.compile.toList
str = getString(bytes)
args <- decode(str).raiseIO
_ <- produce(args).to(writeOutputStream(IO(out), global)).compile.drain
yield Unit).unsafeRunAsyncAndForget() // throws exception in the case of Failure
// ------------------------------------------------
// produce(args: MyCaseClass): fs2.Stream[IO, Byte]
scala aws-lambda fs2
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
add a comment |
I am trying to use fs2.io.writeOutputStream for the output to a Java AWS lambda fn. I don't know how to provide the implicit parameter it's looking for:
"no implicits found for parameter cs: ContextShift[IO]"
I found some documentation for creating my own implicit ContextShift object but that seems like overkill for what I'm trying to do.
final def handleRequest(in: InputStream, out: OutputStream, context: Context): Unit = (for
bytes <- in.compile.toList
str = getString(bytes)
args <- decode(str).raiseIO
_ <- produce(args).to(writeOutputStream(IO(out), global)).compile.drain
yield Unit).unsafeRunAsyncAndForget() // throws exception in the case of Failure
// ------------------------------------------------
// produce(args: MyCaseClass): fs2.Stream[IO, Byte]
scala aws-lambda fs2
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
I am trying to use fs2.io.writeOutputStream for the output to a Java AWS lambda fn. I don't know how to provide the implicit parameter it's looking for:
"no implicits found for parameter cs: ContextShift[IO]"
I found some documentation for creating my own implicit ContextShift object but that seems like overkill for what I'm trying to do.
final def handleRequest(in: InputStream, out: OutputStream, context: Context): Unit = (for
bytes <- in.compile.toList
str = getString(bytes)
args <- decode(str).raiseIO
_ <- produce(args).to(writeOutputStream(IO(out), global)).compile.drain
yield Unit).unsafeRunAsyncAndForget() // throws exception in the case of Failure
// ------------------------------------------------
// produce(args: MyCaseClass): fs2.Stream[IO, Byte]
scala aws-lambda fs2
scala aws-lambda fs2
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
asked Nov 13 '18 at 20:38
codenoodlecodenoodle
417210
417210
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
"By default, Cats Effect can provide instance of ContextShift[IO] that manages thread-pools, but only if there’s an ExecutionContext in scope or if IOApp is used."
-- Cats-effect documentation.
From an ExecutionContext.
import cats.effect.IO, ContextShift
import scala.concurrent.ExecutionContext.Implicits.global
val contextShift = IO.contextShift(global)
Using IOApp.
import cats.effect.IO, IOApp, ContextShift
object Main extends IOApp
override def run(args: List[String]): IO[ExitCode] =
val cs = implicitly[ContextShift[IO]]
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
Thanks! "IO.contextShift(global)" is exactly what I needed.
– codenoodle
Nov 14 '18 at 14:43
add a comment |
Your Answer
StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");
StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);
else
createEditor();
);
function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);
);
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53289140%2fhow-do-i-use-writeoutputstream-with-an-fs2-streamio-byte%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
"By default, Cats Effect can provide instance of ContextShift[IO] that manages thread-pools, but only if there’s an ExecutionContext in scope or if IOApp is used."
-- Cats-effect documentation.
From an ExecutionContext.
import cats.effect.IO, ContextShift
import scala.concurrent.ExecutionContext.Implicits.global
val contextShift = IO.contextShift(global)
Using IOApp.
import cats.effect.IO, IOApp, ContextShift
object Main extends IOApp
override def run(args: List[String]): IO[ExitCode] =
val cs = implicitly[ContextShift[IO]]
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
Thanks! "IO.contextShift(global)" is exactly what I needed.
– codenoodle
Nov 14 '18 at 14:43
add a comment |
"By default, Cats Effect can provide instance of ContextShift[IO] that manages thread-pools, but only if there’s an ExecutionContext in scope or if IOApp is used."
-- Cats-effect documentation.
From an ExecutionContext.
import cats.effect.IO, ContextShift
import scala.concurrent.ExecutionContext.Implicits.global
val contextShift = IO.contextShift(global)
Using IOApp.
import cats.effect.IO, IOApp, ContextShift
object Main extends IOApp
override def run(args: List[String]): IO[ExitCode] =
val cs = implicitly[ContextShift[IO]]
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
Thanks! "IO.contextShift(global)" is exactly what I needed.
– codenoodle
Nov 14 '18 at 14:43
add a comment |
"By default, Cats Effect can provide instance of ContextShift[IO] that manages thread-pools, but only if there’s an ExecutionContext in scope or if IOApp is used."
-- Cats-effect documentation.
From an ExecutionContext.
import cats.effect.IO, ContextShift
import scala.concurrent.ExecutionContext.Implicits.global
val contextShift = IO.contextShift(global)
Using IOApp.
import cats.effect.IO, IOApp, ContextShift
object Main extends IOApp
override def run(args: List[String]): IO[ExitCode] =
val cs = implicitly[ContextShift[IO]]
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
"By default, Cats Effect can provide instance of ContextShift[IO] that manages thread-pools, but only if there’s an ExecutionContext in scope or if IOApp is used."
-- Cats-effect documentation.
From an ExecutionContext.
import cats.effect.IO, ContextShift
import scala.concurrent.ExecutionContext.Implicits.global
val contextShift = IO.contextShift(global)
Using IOApp.
import cats.effect.IO, IOApp, ContextShift
object Main extends IOApp
override def run(args: List[String]): IO[ExitCode] =
val cs = implicitly[ContextShift[IO]]
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
answered Nov 14 '18 at 1:49
Luis Miguel Mejía SuárezLuis Miguel Mejía Suárez
2,79521023
2,79521023
Thanks! "IO.contextShift(global)" is exactly what I needed.
– codenoodle
Nov 14 '18 at 14:43
add a comment |
Thanks! "IO.contextShift(global)" is exactly what I needed.
– codenoodle
Nov 14 '18 at 14:43
Thanks! "IO.contextShift(global)" is exactly what I needed.
– codenoodle
Nov 14 '18 at 14:43
Thanks! "IO.contextShift(global)" is exactly what I needed.
– codenoodle
Nov 14 '18 at 14:43
add a comment |
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53289140%2fhow-do-i-use-writeoutputstream-with-an-fs2-streamio-byte%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
