ro is a Go implementation of the ReactiveX specification, offering a declarative and composable way...