a go reactiveX implementation ref http://reactivex.io/documentation/observable.html
Primary LanguageGoBSD 2-Clause "Simplified" LicenseBSD-2-Clause