diff --git a/terminus-terminal/src/services/sessions.service.ts b/terminus-terminal/src/services/sessions.service.ts
index ca6f3afa..ff4a4d27 100644
--- a/terminus-terminal/src/services/sessions.service.ts
+++ b/terminus-terminal/src/services/sessions.service.ts
@@ -30,12 +30,6 @@ export abstract class BaseSession {
     get closed$ (): Observable<void> { return this.closed }
     get destroyed$ (): Observable<void> { return this.destroyed }
 
-    constructor () {
-        this.output$ = this.output.asObservable()
-        this.closed$ = this.closed.asObservable()
-        this.destroyed$ = this.destroyed.asObservable()
-    }
-
     emitOutput (data: string) {
         if (!this.initialDataBufferReleased) {
             this.initialDataBuffer += data
diff --git a/terminus-terminal/src/services/terminal.service.ts b/terminus-terminal/src/services/terminal.service.ts
index 7b5ad4fb..fdeeec2d 100644
--- a/terminus-terminal/src/services/terminal.service.ts
+++ b/terminus-terminal/src/services/terminal.service.ts
@@ -29,7 +29,6 @@ export class TerminalService {
 
     async reloadShells () {
         this.shells = new AsyncSubject<IShell[]>()
-        this.shells$ = this.shells.asObservable()
         let shellLists = await Promise.all(this.config.enabledServices(this.shellProviders).map(x => x.provide()))
         this.shells.next(shellLists.reduce((a, b) => a.concat(b)))
         this.shells.complete()