Add StreamSignals and fix Observables