fix: free _getEditorEventStream

Author: aminya

src/CodeFormatManager.ts

@@ -78,7 +78,7 @@ export default class CodeFormatManager {
 
     // Events from editor actions (saving, typing).
     const editorEvents = observableFromSubscribeFunction((cb) => atom.workspace.observeTextEditors(cb)).mergeMap(
-      (editor) => this._getEditorEventStream(editor)
+      (editor) => _getEditorEventStream(editor)
     )
 
     return (
@@ -97,22 +97,6 @@ export default class CodeFormatManager {
     )
   }
 
-  /** Returns a stream of all typing and saving operations from the editor. */
-  _getEditorEventStream(editor: TextEditor): Observable<FormatEvent> {
-    const changeEvents = observableFromSubscribeFunction((callback) => editor.getBuffer().onDidChangeText(callback))
-
-    // We need to capture when editors are about to be destroyed in order to
-    // interrupt any pending formatting operations. (Otherwise, we may end up
-    // attempting to save a destroyed editor!)
-    const willDestroyEvents = observableFromSubscribeFunction((cb) => atom.workspace.onWillDestroyPaneItem(cb)).filter(
-      (event) => event.item === editor
-    )
-
-    return Observable.merge(changeEvents.map((edit) => ({ type: "type", editor, edit }))).takeUntil(
-      Observable.merge(observeEditorDestroy(editor), willDestroyEvents)
-    )
-  }
-
   _handleEvent(event: FormatEvent): Observable<unknown> {
     const { editor } = event
     switch (event.type) {
@@ -396,3 +380,19 @@ function _checkContentsAreSame(before: string, after: string): void {
     throw new Error("The file contents were changed before formatting was complete.")
   }
 }
+
+/** Returns a stream of all typing and saving operations from the editor. */
+function _getEditorEventStream(editor: TextEditor): Observable<FormatEvent> {
+  const changeEvents = observableFromSubscribeFunction((callback) => editor.getBuffer().onDidChangeText(callback))
+
+  // We need to capture when editors are about to be destroyed in order to
+  // interrupt any pending formatting operations. (Otherwise, we may end up
+  // attempting to save a destroyed editor!)
+  const willDestroyEvents = observableFromSubscribeFunction((cb) => atom.workspace.onWillDestroyPaneItem(cb)).filter(
+    (event) => event.item === editor
+  )
+
+  return Observable.merge(changeEvents.map((edit) => ({ type: "type", editor, edit }))).takeUntil(
+    Observable.merge(observeEditorDestroy(editor), willDestroyEvents)
+  )
+}