streamdouble
A framework-agnostic Twilio Media Streams simulator. Test your voice agent's WebSocket endpoint locally, at full protocol fidelity, without placing a real call.
Status: early, but it works. Places real calls, records the reply, simulates bad networks, runs scripted scenarios, and gates on latency in CI. Validated against a production voice agent, where it found a real bug. Expect the API to move before 1.0.
The problem
To test a one-line change in a Twilio voice agent today, you start your app, start an ngrok tunnel, trigger a call, make a real phone ring, talk to your own bot until you reach the code path you changed, and get billed for the minute.
It is slow, it costs money, it cannot run in CI, and the Twilio↔app seam — where audio format mismatches, framing errors and silent packet drops actually live — is exactly the seam no existing tool exercises.
streamdouble does one thing: it lies to your WebSocket endpoint convincingly
enough that your agent cannot tell it isn't Twilio.
It says nothing about whether your agent is any good. No transcript scoring, no personas, no LLM-as-judge, no conversation simulation. It tests the transport underneath all of that: framing, timing, protocol conformance, and what happens on a bad line. If you want to know whether your agent handles an angry customer, other tools do that better — this is the layer beneath them.
Try it
No Twilio account, no tunnel, no phone.
pip install streamdouble
Point it at your agent, with any WAV file as the caller's voice:
streamdouble call ws://localhost:8000/media-stream --audio hello.wav --out reply.wav
reply.wav is what your agent said back — open it and listen.
stream MZdcedc700bccdb1f93f6b3334c79dcfa2
sent 100 frames (2.00s)
received 100 media frames (2.00s)
first audio 437 ms
gaps mean 16 ms, p95 34 ms, max 46 ms
marks 1 received, 1 echoed
pacing 100 frames in 1.97s (drift -8.4ms, 51 late, max 15.9ms)
wrote reply.wav (2.00s)
first audio is the one to watch: how long the caller waits before hearing anything. marks are Twilio's playback checkpoints — an agent sends one to ask "has the caller actually heard this yet?", and a reply that never comes back is why some agents hang. pacing is streamdouble reporting on itself, so you can tell a slow agent from a slow measurement.
No voice agent to point it at yet?
This repository ships one, along with the audio to feed it. You need the clone for the example agent, the fixtures and the scenarios; the published package is just the tool itself.
git clone https://github.com/shaswat28/streamdouble
cd streamdouble
pip install -e ".[example]"
Then, in one terminal:
python examples/echo_agent.py --port 8000
and in another:
streamdouble call ws://localhost:8000/media-stream \
--audio fixtures/speech_8k.wav --out reply.wav
The example agent can misbehave on purpose, which is how you see what a failure
looks like. Add ?mode=silent to the URL for an agent that never answers, or
?delay_ms=2000 for a slow one; hangup_after=, garbage_after= and
clear_after= are also there.
Use it as a CI gate
streamdouble call ws://localhost:8000/media-stream --audio hello.wav \
--max-first-audio-ms 800 --json
{
"schema_version": 1,
"time_to_first_audio_ms": 440.7,
"mean_inbound_gap_ms": 15.6,
"p95_inbound_gap_ms": 31.7,
"max_inbound_gap_ms": 60.1,
"stall_count": 0,
"violations": [],
"timed_out": false,
"closed_by": null,
"closed_before_audio": false,
"pacing": {
"drift_ms": 7.6,
"late_frames": 51,
"max_lateness_ms": 25.9,
"mean_lateness_ms": 4.41,
"measurement_is_reliable": true
},
"thresholds": [
{ "name": "first audio", "limit_ms": 800.0, "value_ms": 440.7, "passed": true }
],
"exit_code": 0
}
Exit codes: 0 clean, 1 a threshold failed, 2 the agent never spoke,
3 the agent violated the protocol, 4 usage error, 5 could not connect.
"Never spoke" is either timed_out (it stayed quiet) or closed_before_audio
(the connection closed first); closed_by says who closed it -- agent,
caller (a scenario's hangup), or streamdouble when the websockets library
closed it, e.g. over an oversized frame.
Two things that behaviour turns on, both deliberate:
- An agent that said nothing fails its latency threshold. Its
time_to_first_audio_msisnull, not0— silence is the worst outcome, not the fastest one, and treating missing data as a pass is how a broken agent gets a green build. Use--allow-no-audioif you disagree. measurement_is_reliablereports on the tool itself. If pacing slipped persistently, audio reached your agent late and the latency above is an upper bound. A latency tool that reports wrong latency is worse than no tool, so it says so rather than quietly looking precise. Judged on mean lateness, so one unrelated stall does not condemn a measurement taken thousands of frames earlier —max_lateness_msis published alongside for the full picture.
For a CI test-report viewer, add a JUnit XML report:
streamdouble call ws://localhost:8000/media-stream --audio hello.wav \
--max-first-audio-ms 800 --junit junit.xml
Each threshold, scenario expectation, protocol check and timeout is its own
testcase. A final verdict case fails whenever the exit code is non-zero, so
the report is never greener than the job. A threshold on a metric that was
never measured is a failure; under --allow-no-audio it is skipped, not
passed, because nothing was checked.
Where 800 ms comes from: human turn-taking gaps cluster at
0–200 ms across languages
(Stivers et al., PNAS 2009). The 800 ms figure itself is an industry rule of
thumb for voice agents rather than a research finding — metrics.py says so
too, rather than borrowing the paper's authority for it.
Use it from pytest
Most people testing a voice agent already have a pytest suite. Installing the package registers a fixture, so a call is one line in it:
async def test_the_agent_answers_quickly(simulated_call):
report = await simulated_call(AGENT_URL, audio="hello.wav")
assert report.spoke
assert report.time_to_first_audio_ms < 800
No shelling out, no parsing JSON. The CLI is a renderer over the same API, so
what you assert on here and what --json prints cannot disagree.
An agent that never spoke has time_to_first_audio_ms of None, and the
plugin explains that failure rather than leaving you with a bare TypeError.
Full reference, including per-suite configuration and the pytest-asyncio
setting you need: docs/python-api.md.
Catch a regression an absolute threshold cannot see
An agent that answered in 300 ms and now answers in 700 ms has got more than
twice as slow — and still passes --max-first-audio-ms 800. That is the
regression teams actually care about, and it needs a baseline rather than a
limit.
# once, on a known-good build
streamdouble call ws://localhost:8000/media-stream --audio hello.wav \
-n 20 --save-baseline baseline.json
# in CI, from then on
streamdouble call ws://localhost:8000/media-stream --audio hello.wav \
-n 20 --baseline baseline.json
20 runs, 0 failed
median min max p95 stddev n
first audio 181.7 166.4 194.1 193.2 9.2 20/20
mean gap 18.2 18.1 18.3 18.3 0.1 20/20
delivery ratio 1.1 1.1 1.2 1.2 0.0 20/20
against the baseline:
first audio 181.7 -> 585.8 (+404.1, +222%) REGRESSION
A regression exits 1, same as a failed threshold — it is the same kind of fact.
-n is a distribution, not a retry. There is no --retries and there will
not be: repeating a call to measure its spread is useful, repeating it until it
passes hides a flaky agent, and a tool that offers the second cannot be trusted
about the first. Runs are sequential, never parallel — concurrent calls delay
each other's frames and would corrupt the statistics being gathered.
Three things the check refuses to do:
- Compare incomparable runs. The baseline records a hash of the clip's contents, the chaos seed and the impairments. Swap your test audio and it says so and exits 4, rather than reporting a "regression" that is really two different experiments being subtracted. It refuses before placing a single call, since everything it needs to know is known beforehand.
- Fire on noise. A change must exceed both a percentage and an absolute floor. 5 ms becoming 8 ms is 60% worse and inaudible; 2000 ms becoming 2040 ms is 40 ms and nobody notices. Neither fails your build.
- Treat a missing measurement as an improvement. An agent that has stopped
speaking has
nullwhere it had 400 ms. Subtracting those would report a cheerful "−400 ms"; instead it readswas 181.7, now never measuredand counts as the most serious regression there is.
Below 20 runs the P95 is withheld and the output says why, because a P95 over five samples is the maximum wearing a statistical hat.
In GitHub Actions
- uses: shaswat28/streamdouble@main
with:
url: ws://localhost:8000/media-stream
audio: fixtures/hello.wav
repeat: "20"
baseline: baseline.json
max-first-audio-ms: "800"
The JSON results and the frame trace are uploaded as an artifact on every run, including failures — a failing run is the one whose trace you want.
Script a whole call
A single clip is one test. The bugs live in the timing between things — the caller interrupting, saying nothing, pressing a key, hanging up early.
# scenarios/barge_in.yaml
name: caller interrupts the greeting
steps:
- wait_for: audio # let the agent get going
- wait: 1.5 # streaming silence, not stopping
- say: ../fixtures/speech/interrupt.wav
- expect: clear # a correct agent stops talking
- wait: 1.0
Scenarios and their clips live next to each other, so this one runs from a clone of this repository:
python fixtures/make_speech.py # once: real speech, from your OS's own TTS
streamdouble scenario scenarios/barge_in.yaml ws://localhost:8000/media-stream
For your own project, write the YAML wherever you like and keep the clips
beside it — say: paths resolve relative to the scenario file.
Barge-in needs real speech, and this is the trap. Most agents trigger barge-in when their transcription service produces words. The synthetic fixtures in this repo are speech-like — right for codec tests, and no STT will ever turn them into words. Drive a barge-in test with one and the agent never reacts, the test fails, and it looks like an agent bug. It is not.
fixtures/make_speech.py generates transcribable clips using the TTS already on
your machine — SAPI on Windows, say on macOS, espeak-ng on Linux. No
recording, no API cost. Verified end to end: a real streaming transcription
service returned the exact sentence, and the agent's barge-in fired on it. The
output is gitignored, so generate your own (or drop in real recordings, which
are better — real callers have accents and trail off mid-sentence).
A failed expect exits 1, so a scenario is a CI check. Scenarios are validated
before the socket opens — a typo cannot fail halfway through with your agent
mid-sentence.
wait streams silence; it does not stop sending. A real call carries 20 ms
frames continuously for its whole duration, and voice-activity detection depends
on that. A simulator that goes quiet looks like a dead line rather than a quiet
caller, and the resulting "my agent never finalises the transcript" is a bug in
the test tool.
See what actually went over the wire
streamdouble call ws://localhost:8000/media-stream --audio hello.wav \
--trace call.jsonl
One JSON object per frame, both directions, with timings. This is the artefact to attach when you think the simulation is wrong rather than your agent -- which is the most valuable bug report this project can receive.
Audio payloads are left out by default, because a minute of a call is about
30 MB of base64 nobody reads; a hash of each is kept so two traces stay
comparable. --trace-payloads includes them. customParameters values are
redacted, because --param is how agents are authenticated and a trace exists
to be sent to someone else; --trace-secrets opts out.
Nothing is written while the call is running. A trace that changed the latency it was recording would not be a diagnostic.
To read one back without scrolling through it:
streamdouble inspect call.jsonl
It prints whether the agent spoke and when, its marks and which were echoed, any
clears, gaps in the agent's audio, and anything that arrived malformed or out
of sequence. Add --json for the same data as JSON. An agent that never spoke
reads as none, not 0 ms. It opens no socket, and it treats the file as
untrusted, so it is safe to run on a trace someone attached to an issue.
Simulate a bad connection
streamdouble call ws://localhost:8000/media-stream --audio hello.wav \
--packet-loss 0.05 --jitter 40 --latency 120 --chaos-seed 7
Impairments are seeded, so a run that finds a bug replays exactly — pass the
same --chaos-seed and you get the same call. A chaos feature you cannot replay
is not a test tool, it is a random number generator that occasionally fails your
build.
Packet loss is modelled as audio Twilio never received, so the agent sees
media.timestamp jump rather than a frame go missing. The Twilio↔app leg is a
WebSocket, which is TCP: a frame cannot vanish in transit. chaos.py explains
the reasoning, and flags it as an inference the docs do not cover.
Hear both sides of the call
streamdouble call ws://localhost:8000/media-stream --audio hello.wav \
--record-stereo call.wav
Caller on the left, agent on the right, in one file.
The agent's channel is placed at the instants its audio arrived, with real silence in the gaps — not concatenated. That distinction is the whole point. Agents batch their outbound audio: the bug this tool is best known for finding was an agent sending 9.5 seconds of speech in 0.85 seconds, leaving the caller listening for another 8.7 seconds while the agent believed it had finished. Concatenating those frames would render that as a smooth, perfectly-timed reply — a picture of the opposite of the bug. Placed at arrival times, you can hear the burst and the silence after it.
Fork mode: the other half of Media Streams
<Connect><Stream> is the bidirectional call an agent answers, and it is what
everything above simulates. <Start><Stream> is the other half — a one-way
fork, which is what transcription and compliance-recording apps consume.
streamdouble call ws://localhost:8000/media-stream-fork --audio hello.wav \
--fork --track both --agent-audio agent-reply.wav
A fork is one-way, and two things follow:
- No mark echo, and no
clear. The Twilio docs say verbatim that "Twilio sends themarkevent only during bidirectional Streams", so a simulator that echoed marks here would be inventing a message real Twilio never sends. --agent-audiois required for an outbound track. On a real fork Twilio copies the agent's own audio to the app, so streamdouble has to supply both halves. Streaming silence instead would not be a simpler simulation, it would be a wrong one.
An app that sends media back on a fork gets a warning, and the run still
passes. The Twilio docs state the bidirectional case affirmatively and say
nothing about this one, so treating it as a violation is streamdouble's
inference rather than a documented rule — and this project does not fail your
build on an inference unless you ask. --strict-fork is the asking.
How this compares
Everything below does something streamdouble does not, and most of them are the
thing you actually want first. streamdouble tests one seam that none of them
test. Read this as "which problem do you have", not as a ranking.
| What it is | Where it's stronger | Where streamdouble is | |
|---|---|---|---|
| Pipecat Evals | Describe a conversation and the expected behaviour; it runs against your real agent | Semantic correctness — did the agent say the right thing, take the right action. First-party and free | Only works on Pipecat agents. Does not exercise the Twilio wire format |
| LiveKit testing | pytest-based agent tests, text mode by default, optional audio simulation | Fast, deterministic, cheap in text mode. Excellent if you're on LiveKit | Tied to LiveKit agents. Text mode skips the audio path entirely |
| Hamming / Cekura / TestMu | Hosted QA: simulated callers, personas, LLM-judged scoring, production monitoring | Conversation quality at scale, regression suites, dashboards, monitoring real traffic | Paid, hosted, and aimed at what the agent says rather than how audio reaches it |
| Twilio CLI | Official tooling, including webhook tunnelling | Everything else Twilio — TwiML, calls, numbers, HTTP webhooks | Doesn't simulate Media Streams. Webhooks are HTTP; this is the WebSocket leg |
| streamdouble | Speaks the Twilio Media Streams protocol at your endpoint | The transport seam: μ-law framing, 20 ms pacing, mark echo, timing, packet loss. Framework-agnostic, local, free, no account | Says nothing about whether your agent is any good. No transcript scoring, no personas, no judgement |
The honest summary: if you want to know whether your agent handles an angry customer, use one of the others. If you want to know whether your agent handles a caller on a bad connection who interrupts mid-sentence — or whether it handles Twilio's wire format correctly at all — that is the gap this fills.
They compose. streamdouble is the layer underneath: it makes the transport trustworthy so that when a behavioural test fails, you know it failed for a behavioural reason.
What it found in practice. Pointed at a real production voice agent for the first time, it found a barge-in blind spot: the agent streamed 9.5 s of speech in 0.85 s, cleared its "am I speaking" flag when sending finished, and was therefore deaf to interruption for the 8.7 s the caller was still listening. No transcript-scoring tool would have seen that, because every transcript was correct.
A simulated call is still a real call
streamdouble removes the phone, the tunnel and the Twilio charge. It does not remove anything that happens after your agent's WebSocket handler runs.
The first time this was pointed at a production voice agent, the call completed normally and then wrote three records to a live CRM for a made-up phone number, because the agent pushes call outcomes on hangup. That is correct behaviour by the agent. It is just not what you want from a test.
Before pointing streamdouble at a real agent, check what a completed call touches — CRM pushes, databases, webhooks, notification sends, billing — and disable them:
TWENTY_API_KEY="" CRM_BASE_URL="" python -m uvicorn app.main:app --port 8000
The rule of thumb: everything downstream of the socket cannot tell the difference, and it is not supposed to be able to. That is the whole point of the tool, and it is exactly why this needs saying.
Scope
What it does: speaks the Twilio Media Streams protocol — connected,
start, media, dtmf, stop outbound; media, mark, clear inbound —
with correct μ-law encoding, 20 ms framing, real-time pacing, and mark echo.
Marks are echoed, not just logged. Twilio returns a mark once the audio
queued before it has finished playing to the caller, and many agents gate
turn-taking on that echo — so streamdouble models a playback clock and echoes
each mark when its audio would have drained. A clear discards the buffer and
the marks queued behind it, because that audio is never going to play.
Development
pip install -e ".[dev]"
pytest # the session tests run against a real socket
ruff check .
Fixtures are generated and committed; regenerate with
python fixtures/make_fixtures.py only if a fixture definition changes.
CI runs the suite on Linux and Windows across Python 3.11, 3.12 and 3.13.
3.13 matters specifically: audioop was removed there, so that run proves the
μ-law codec stands on its own rather than leaning on the stdlib.
A note on timing accuracy
Pacing schedules against absolute deadlines from a fixed origin, so error does not accumulate over a long call.
Timing uses time.perf_counter, not time.monotonic. The distinction is not
pedantry: on Windows CPython implements monotonic with GetTickCount64, whose
resolution is 15.625 ms — comparable to the entire 20 ms frame being
measured. Using it quantised every reported latency onto that grid while
printing it to a tenth of a millisecond, and made the pacer's own lateness
statistics measure the clock instead of the pacing. Every run reported max
lateness of exactly 15.0 or 16.0 ms, which is one tick.
With perf_counter (100 ns), the two effects separate. streamdouble publishes
both max and mean lateness, and derives measurement_is_reliable from the mean,
so one unrelated stall does not condemn a measurement taken thousands of frames
earlier.
Windows' scheduler is the other half. asyncio waits on the system timer tick,
15.625 ms by default, so paced frames wake up to a tick late. During a call,
streamdouble asks Windows for a 1 ms timer (timeBeginPeriod, released when
the call ends and scoped to this process). On real calls on the development
machine, mean lateness fell from 4.3 ms to 1.3 ms and max lateness from 28.8 ms
to 6.7 ms. Time to first audio did not move, which is the point: the pacing
got more precise, not the latency more flattering. pacing.timer in the JSON
records the outcome: raised, refused,
or not needed off Windows. A lateness figure means something only when you
know which timer produced it.
PLAN.md records the build plan, the decisions taken, and what each review gate
found.
Use it from Claude Code
skill/SKILL.md is a Claude Code skill wrapper. Copy it into .claude/skills/
and Claude can drive streamdouble directly — "test this agent with a caller who
interrupts", "is it answering fast enough", "why does barge-in not fire".
It carries the judgement that matters as much as the commands: disable whatever
your agent touches on hangup before the first call, never report a null
latency as fast, and do not diagnose barge-in with synthetic audio, because a
transcription service will not transcribe it and the test fails for the wrong
reason.
Notes
Six ways to get Twilio Media Streams audio wrong —
what building this turned up, including why μ-law silence is 0xFF, why one
code exists that no encoder emits, and why "finished sending" is not "finished
speaking".
Changelog
Not affiliated with Twilio
This project is not affiliated with, endorsed by, or sponsored by Twilio. It simulates the publicly documented Twilio Media Streams protocol for testing purposes. "Twilio" is a trademark of Twilio Inc.
License
Apache-2.0. See LICENSE.
Metadata
Release files for streamdouble 0.3.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| streamdouble-0.3.0.tar.gz | 881.2 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| streamdouble-0.3.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 994.8 kB
Release files / streamdouble-0.3.0.tar.gz
| Download URL | streamdouble-0.3.0.tar.gz |
|---|---|
| Size | 881.2 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
cc2e6c3c80b55fa10d6d7b0e4aa61c04e2a9a346a7bcd3ed939cd2e79577da0a
|
|
BLAKE2b-256 checksum How to use checksums |
bd1ddb16b3324af9011643f7d9bfd82e4cd793b6dcda7a6eb979586d7b1c683a
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.12.14
|
Release files / streamdouble-0.3.0-py3-none-any.whl
| Download URL | streamdouble-0.3.0-py3-none-any.whl |
|---|---|
| Size | 113.6 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
930587711852833e2666e8b3133c081d3418e83316fe1927c9977418b9b2693c
|
|
BLAKE2b-256 checksum How to use checksums |
460a60f56f40e69b91fc47f3968a9d5cc73498ca582cc436ee2a24e21f91f6d4
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.12.14
|