Implement in-memory observables