Wiring file watch events WIP

src/app/common/services/editor/editors.service.ts

@@ -1,5 +1,5 @@
 import { ComponentRef, Injectable } from '@angular/core';
-import { BehaviorSubject, ReplaySubject, Observable } from 'rxjs';
+import { ReplaySubject, Observable } from 'rxjs';
 
 import { NewtonEditorComponent } from "../../../editor/newton-editor/newton-editor.component";
 

src/app/common/services/editor/files.service.ts

@@ -1,4 +1,5 @@
 import { Injectable } from '@angular/core';
+import { ReplaySubject, Observable } from 'rxjs';
 
 import { EditSession } from 'ace-builds';
 import { getModeForPath } from 'ace-builds/src-noconflict/ext-modelist';
@@ -14,6 +15,8 @@ import { ServiceMessage } from '../../types/service-message.type';
     providedIn: 'root'
 })
 export class FilesService {
+    private messageSubject: ReplaySubject<ServiceMessage> = new ReplaySubject<ServiceMessage>(1);
+
     files: Map<string, NewtonFile>;
 
 
@@ -38,7 +41,13 @@ export class FilesService {
         this.files.set(file.path, file);
     }
 
+    sendMessage(data: ServiceMessage): void {
+        this.messageSubject.next(data);
+    }
 
+    getMessage$(): Observable<ServiceMessage> {
+        return this.messageSubject.asObservable();
+    }
 
     async loadFilesList(files: Array<NewtonFile>): Promise<NewtonFile | undefined | null> {
 	    for (let i = 0; i < files.length; i++) {