Better yet: what behavior do you want?
that because I have to use
IO
So ultimately, your app will have a
run(args: List[String]): IO[ExitCode] method.
It might contain something like
IO.fromFuture(...runWith(Sink.foreach(println))).as[ExitCode.Success]
But at this point, yeah, I have to suggest not using Akka Streams, if you want to use http4s.
The point of
IOApp is that it takes care of running the IO[ExitCode] for you.
Well, that's one point, anyway.
Yout
Sink.foreach is calling println, so you should see your output fine.
That is, your whole expression constructs a
Future[Done], which has a thread that prints the ticks, right?
Well, if you return
ExitCode.Failure, IIRC, when the JVM halts, Linux (or macOS or whatever) will have its "errno" be -1, or somesuch.
https://ovotech.github.io/fs2-kafka/ is awesome
Sorry if this is documented somewhere, but I seem to write a lot of code of the form
if(condition) effect else IO(Unit) where effect is IO[Unit]. What's a better way to do this to avoid having to write else IO(Unit)? Right now I just have a function def ifIO(condition: => Boolean, effect:IO[Unit]): IO[Unit] to do that very thing, but I figure this is so simple it must have an idiomatic solution I'm missing.
I've been meaning for a while to PR in syntax to allow
condition.whenA(effect)
It would also be reasonable for
IO to expose this as a method on the companion or even effect.whenA(cond) as a method on IO
Would be nice if someone can help https://stackoverflow.com/questions/58105251/how-to-wrap-effectful-f-instead-of-the-concrete-type-constructor
