diff --git a/test/timeout_repro_test.dart b/test/timeout_repro_test.dart
new file mode 100644
index 0000000..f5c67b0
--- /dev/null
+++ b/test/timeout_repro_test.dart
@@ -0,0 +1,70 @@
+@TestOn('vm')
+import 'dart:async';
+
+import 'package:grpc/grpc.dart';
+import 'package:test/test.dart';
+
+import 'src/generated/echo.pbgrpc.dart';
+
+void main() {
+  late Server server;
+  late EchoServiceClient fakeClient;
+  late ClientChannel fakeChannel;
+
+  setUp(() async {
+    server = Server.create(
+      services: [EchoService()],
+      codecRegistry: CodecRegistry(
+        codecs: const [GzipCodec(), IdentityCodec()],
+      ),
+    );
+    await server.serve(address: 'localhost', port: 8081);
+    final options = ChannelOptions(
+      credentials: const ChannelCredentials.insecure(),
+      codecRegistry: CodecRegistry(
+        codecs: const [GzipCodec(), IdentityCodec()],
+      ),
+    );
+    fakeChannel = ClientChannel(
+      'localhost',
+      port: server.port!,
+      options: options,
+    );
+    fakeClient = EchoServiceClient(fakeChannel);
+  });
+
+  tearDown(() async {
+    await fakeChannel.shutdown();
+    await server.shutdown();
+  });
+
+  test('Ping twice', () async {
+    final callOptions = CallOptions(
+      timeout: Duration(microseconds: 50),
+    );
+    for (var i = 0; i < 100; i++) {
+      expectLater(
+        () => fakeClient.echo(
+          EchoRequest(message: 'some message'),
+          options: callOptions,
+        ),
+        throwsA(isA<GrpcError>()),
+      );
+    }
+  });
+}
+
+class EchoService extends EchoServiceBase {
+  @override
+  Future<EchoResponse> echo(ServiceCall call, EchoRequest request) async {
+    await Future.delayed(Duration(milliseconds: 1));
+    return EchoResponse(
+        message: String.fromCharCodes(request.message.codeUnits.reversed));
+  }
+
+  @override
+  Stream<ServerStreamingEchoResponse> serverStreamingEcho(
+      ServiceCall call, ServerStreamingEchoRequest request) {
+    throw UnimplementedError();
+  }
+}