diff --git a/adapters/reflexstreamer/go.mod b/adapters/reflexstreamer/go.mod
index a42fe09..b9adc45 100644
--- a/adapters/reflexstreamer/go.mod
+++ b/adapters/reflexstreamer/go.mod
@@ -7,7 +7,7 @@ replace github.com/luno/workflow => ../..
 require (
 	github.com/corverroos/truss v0.0.0-20210514115035-9e5e1b0851a9
 	github.com/luno/jettison v0.0.0-20250424095956-76a91fb3568f
-	github.com/luno/reflex v0.0.0-20250306163217-c9f47c5e6287
+	github.com/luno/reflex v0.0.0-20250313101922-d2735e11add1
 	github.com/luno/workflow v0.3.0
 	github.com/stretchr/testify v1.10.0
 )
diff --git a/adapters/reflexstreamer/go.sum b/adapters/reflexstreamer/go.sum
index ee03622..64e8eaa 100644
--- a/adapters/reflexstreamer/go.sum
+++ b/adapters/reflexstreamer/go.sum
@@ -54,8 +54,8 @@ github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+
 github.com/luno/jettison v0.0.0-20210218093327-95083f929b49/go.mod h1:IVntidW2Z2luwfdIpwgvUZSwnRk82RRPfoj0h2P7W+c=
 github.com/luno/jettison v0.0.0-20250424095956-76a91fb3568f h1:3ohPEKMJf7OEF/HdqmmfBdSFKujsDCI+Wbn5IUgp6TQ=
 github.com/luno/jettison v0.0.0-20250424095956-76a91fb3568f/go.mod h1:nanRKtu6/pmqct9oq1nmu33JEkAdSjfp03kYLkCMnJc=
-github.com/luno/reflex v0.0.0-20250306163217-c9f47c5e6287 h1:J+9TpS5Q7pyJN5Ip9fm1+6wdQT6I+5P7iMV5joI9bF8=
-github.com/luno/reflex v0.0.0-20250306163217-c9f47c5e6287/go.mod h1:ObnEcIpONOvF1O0qrPJ7RsqSy01MvGYelggRBYkhbMc=
+github.com/luno/reflex v0.0.0-20250313101922-d2735e11add1 h1:oTYnJAQhNVPTUZ2sNFeRwUjcdilesxXsRElgJ8c3NVU=
+github.com/luno/reflex v0.0.0-20250313101922-d2735e11add1/go.mod h1:2K8a80He8sipIVNfniACVcBMrn3S1l5bwWHC1fJMUrI=
 github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
 github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
 github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=