This reminds me of rxjs.