Stimulation Options

• maxNeuronHops?: number — limit traversal depth
• onResponse?: (response) => void | Promise<void> — tap into flow and completion (async supported)
• abortSignal?: AbortSignal — graceful cancel
• concurrency?: number — per-run concurrency limit
• ctx?: ICNSStimulationContextStore — reuse context store (in‑process)
• modality?: TCNSModality — optional modality routing for modalityDendrite
• afferentPath?: TCNSAfferentPath — optional afferent path selection for modalityDendrite
• stimulationContext?: object — optional user-defined bag for listeners/handlers
• onDrain?: (drain) => void — called once at the end of every synchronous turn; the batch boundary for state managers (see API reference)

const controller = new AbortController();
const stimulation = cns.stimulate(signal, {
  maxNeuronHops: 10, // optional, disabled by default
  abortSignal: controller.signal,
  onResponse: r => {
    // queueLength counts pending + in-flight activations, so zero means the
    // whole stimulation is finished - not merely that a batch ended.
    if (r.queueLength === 0) console.log('done');
  }
});
await stimulation.waitUntilComplete();

Async listeners and failure semantics

• Local onResponse and all global listeners (added via addResponseListener) can be synchronous or asynchronous.
• They run in parallel for each response. If any throws or returns a rejected Promise, the stimulation.waitUntilComplete() Promise rejects.
• A dendrite response that throws or returns a rejected Promise also fails the run (a failed task) and rejects waitUntilComplete() — independent of any listener.
• If all listeners are synchronous, CNStra does not introduce extra async deferrals for that response.

⚠️ stimulate() returns a CNSStimulation, not a Promise — the completion Promise is created lazily by waitUntilComplete(). If you neither await it nor register a listener, a failed run is swallowed silently (not even an unhandled rejection). See Error Handling → Fire-and-forget.

// Async onResponse example (e.g., persist to DB/Redis)
const stimulation = cns.stimulate(signal, {
  onResponse: async (r) => {
    if (r.outputSignal) {
      await repo.save(r.outputSignal);
    }
  }
});
await stimulation.waitUntilComplete();