go-observer
go-observer copied to clipboard
imkira
Go package for simplifying channel-based broadcasting of events from multiple publishers to multiple observers
Hello. I've revived https://github.com/imkira/go-observer/pull/6
In anticipation of generics with go 1.18, I thought I'd incorporate generics into the project. Please let me know if there's anything you'd like to see done.
Hello. Thanks for the interesting library! We were faced with the need for a mechanism for stopping observers without stopping the property: ```golang package main import ( "fmt" "math/rand" "time"...
Hi, I'm trying to implement some sort of Rx-like stream operators. For instance, I would like to be able to "filter" or "map" messages on a Stream. Any idea on...
How does an observer from say Android connect to this assuming I have an API.
I added some convenience methods to wait only for a subset of stream values: The caller can pass a filter function to the WaitFiltered methods. The WaitFiltered methods only return...
