MCPcopy Create free account
hub / github.com/continuedev/continue / enqueueMessage

Method enqueueMessage

extensions/cli/src/stream/messageQueue.ts:27–48  ·  view source on GitHub ↗
(
    message: string,
    imageMap?: Map<string, Buffer>,
    history?: InputHistory,
  )

Source from the content-addressed store, hash-verified

25 }
26
27 async enqueueMessage(
28 message: string,
29 imageMap?: Map<string, Buffer>,
30 history?: InputHistory,
31 ): Promise<boolean> {
32 const queuedMessage: QueuedMessage = {
33 message,
34 imageMap,
35 timestamp: Date.now(),
36 history,
37 };
38
39 this.queue.push(queuedMessage);
40 logger.debug("MessageQueue: Message queued", {
41 queueLength: this.queue.length,
42 });
43
44 // Emit event for UI to show the queued message
45 this.emit("messageQueued", queuedMessage);
46
47 return true;
48 }
49
50 /**
51 * Dequeues and returns the next message to be processed (FIFO - oldest first)

Callers 4

serveFunction · 0.80
handleEnterKeyFunction · 0.80

Calls 3

pushMethod · 0.65
emitMethod · 0.65
debugMethod · 0.45

Tested by

no test coverage detected