+
Skip to content

Conversation

armanbilge
Copy link
Owner

No description provided.

Comment on lines -100 to -101
extension [F[_], A, B](pipe: Pipe[F, A, B])
def channel(using F: Concurrent[F]): Resource[F, Channel[F, A]] =
Copy link
Owner Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I can't remember what I thought this would be useful for. Anyway, I think most likely you want to convert a Stream to a Signal with hold*. Not a Channel :)

Comment on lines +85 to +86
def zoom[B](lens: Lens[A, B])(using Functor[F]): SignallingRef[F, B] =
SignallingRef.lens[F, A, B](sigRef)(lens.get(_), a => b => lens.replace(b)(a))
Copy link
Owner Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This seems useful, right? 😅

@armanbilge armanbilge merged commit 2eb6389 into main Jan 25, 2023
@armanbilge armanbilge deleted the pr/cleanup-syntax branch January 25, 2023 19:17
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants

点击 这是indexloc提供的php浏览器服务,不要输入任何密码和下载