-
Notifications
You must be signed in to change notification settings - Fork 42
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
EmitterBuilder to create IO[R] #195
Comments
cornerman
added a commit
to cornerman/outwatch
that referenced
this issue
Jul 21, 2018
cornerman
added a commit
to cornerman/outwatch
that referenced
this issue
Jul 21, 2018
LukaJCB
pushed a commit
that referenced
this issue
Jul 24, 2018
cornerman
added a commit
that referenced
this issue
Mar 18, 2019
cornerman
added a commit
to cornerman/outwatch
that referenced
this issue
Sep 24, 2021
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
I was just trying to create a custom EmitterBuilder for some modifier combiniation, but was not able to model this properly. When creating a
SimpleEmitterBuilder[E,R]
, I can provide a create functionObserver[E] => R
, whose result is then wrapped with IO.pure.In this case, I want to return an
IO[R]
, which does not work as expectedNow
def -->(sink: Sink[_ >: E]): IO[R] = IO.pure(create(sink.observer))
will yield anIO[IO[Modifier]]
, which is not really usable.Any ideas how to use this? Or should we make a version with
IO[R]
?Additionally, having a
Sink
instead of an observer would be preferable.The text was updated successfully, but these errors were encountered: