Revert "Re-add throttling with a source queue (firefox-devtools#4948)"

This reverts commit 2d50f0e.

Author: jasonLaster

src/actions/navigation.js

@@ -3,7 +3,6 @@
  * file, You can obtain one at <http://mozilla.org/MPL/2.0/>. */
 
 import { clearDocuments } from "../utils/editor";
-import sourceQueue from "../utils/source-queue";
 import { getSources } from "../reducers/sources";
 import { waitForMs } from "../utils/utils";
 import { newSources } from "./sources";
@@ -33,7 +32,6 @@ export function willNavigate(_, event) {
     clearASTs();
     clearScopes();
     clearSources();
-    sourceQueue.clear();
 
     dispatch(navigate(event.url));
   };

src/actions/sources.js

@@ -114,19 +114,8 @@ export function newSources(sources: Source[]) {
       source => !getSource(getState(), source.id)
     );
 
-    if (filteredSources.length == 0) {
-      return;
-    }
-
-    dispatch({
-      type: "ADD_SOURCES",
-      sources: filteredSources
-    });
-
     for (const source of filteredSources) {
-      dispatch(loadSourceMap(source));
-      dispatch(checkSelectedSource(source));
-      dispatch(checkPendingBreakpoints(source.id));
+      dispatch(newSource(source));
     }
   };
 }
@@ -153,7 +142,6 @@ function createOriginalSource(
 function loadSourceMap(generatedSource) {
   return async function({ dispatch, getState, sourceMaps }: ThunkArgs) {
     const urls = await sourceMaps.getOriginalURLs(generatedSource);
-
     if (!urls) {
       // If this source doesn't have a sourcemap, do nothing.
       return;

src/client/firefox/events.js

@@ -13,7 +13,6 @@ import type {
 } from "./types";
 
 import { createPause, createSource } from "./create";
-import sourceQueue from "../../utils/source-queue";
 import { isEnabled } from "devtools-config";
 
 const CALL_STACK_PAGE_SIZE = 1000;
@@ -32,7 +31,6 @@ function setupEvents(dependencies: Dependencies) {
   threadClient = dependencies.threadClient;
   actions = dependencies.actions;
   supportsWasm = dependencies.supportsWasm;
-  sourceQueue.initialize({ actions, supportsWasm, createSource });
 
   if (threadClient) {
     Object.keys(clientEvents).forEach(eventName => {
@@ -55,7 +53,6 @@ async function paused(_: "paused", packet: PausedPacket) {
 
   if (why.type != "alreadyPaused") {
     const pause = createPause(packet, response);
-    sourceQueue.flush();
     actions.paused(pause);
   }
 }
@@ -65,7 +62,7 @@ function resumed(_: "resumed", packet: ResumedPacket) {
 }
 
 function newSource(_: "newSource", { source }: SourcePacket) {
-  sourceQueue.queue(source);
+  actions.newSource(createSource(source, { supportsWasm }));
 
   if (isEnabled("eventListeners")) {
     actions.fetchEventListeners();

src/client/firefox/types.js

@@ -221,7 +221,7 @@ export type ListTabsResponse = {
 export type Actions = {
   paused: Pause => void,
   resumed: ResumedPacket => void,
-  newSources: (Source[]) => void,
+  newSource: Source => void,
   fetchEventListeners: () => void
 };
 

src/main.js

@@ -12,7 +12,6 @@ import { isFirefoxPanel } from "devtools-config";
 
 import { onConnect } from "./client";
 import { teardownWorkers } from "./utils/bootstrap";
-import sourceQueue from "./utils/source-queue";
 
 if (process.env.NODE_ENV !== "production") {
   window.Perf = require("react-addons-perf");
@@ -44,7 +43,6 @@ if (isFirefoxPanel()) {
     },
     destroy: () => {
       unmountRoot(ReactDOM);
-      sourceQueue.clear();
       teardownWorkers();
     }
   };

src/reducers/sources.js

@@ -55,14 +55,16 @@ function update(
 
   switch (action.type) {
     case "ADD_SOURCE": {
-      return updateSource(state, action.source);
+      const source = action.source;
+      return updateSource(state, source);
     }
 
     case "ADD_SOURCES": {
-      return action.sources.reduce(
-        (newState, source) => updateSource(newState, source),
-        state
-      );
+      action.sources.forEach(source => {
+        state = state.mergeIn(["sources", source.id], source);
+      });
+
+      return state;
     }
 
     case "SELECT_SOURCE":