Package org.mockserver.llm

Class StreamingPhysicsExpander

java.lang.Object

org.mockserver.llm.StreamingPhysicsExpander

public class StreamingPhysicsExpander
extends Object

Applies streaming physics (timing delays) to a list of SSE events.

Algorithm (per spec section 2.3.2):

• If physics is null or all fields are null, return the events unchanged.
• Event 0 delay = timeToFirstToken (default 0 ms).
• Events 1..n delay = baseDelay * (1 + uniform(-jitter, +jitter)) where baseDelay = 1000 / tokensPerSecond ms.
• Uses java.util.Random seeded with physics.seed (default System.nanoTime()) for reproducible jitter.

Method Summary

Modifier and Type	Method	Description
static List<SseEvent>	applyPhysics(List<SseEvent> rawEvents, StreamingPhysics physics)	Apply streaming physics delays to SSE events.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

applyPhysics

public static List<SseEvent> applyPhysics(List<SseEvent> rawEvents,
                                          StreamingPhysics physics)

Apply streaming physics delays to SSE events.

Parameters:

rawEvents - the raw events from the codec (not mutated)

physics - streaming physics parameters (may be null)

Returns:

a new list of events with per-event delays set