diff --git a/dap/accumulator.py b/dap/accumulator.py
index 8c911c1..1947b65 100644
--- a/dap/accumulator.py
+++ b/dap/accumulator.py
@@ -71,6 +71,10 @@ def accumulate(accumulator_addr, bsread_host, bsread_port, bsread_window):
         if not sender:
             continue
 
+        enable_bsread = results.get("enable_bsread", False)
+        if not enable_bsread:
+            continue
+
         timestamp = tuple(results["timestamp"])
         data = pack_bsread_data(results, detector, skip=ENTRIES_TO_SKIP)
         sorter.add(pulse_id, (timestamp, data))