🎉 feat: rapid stream

Author: SaltyAom

CHANGELOG.md

@@ -1,14 +1,17 @@
 # 1.4.13 - 23 Oct 2025
-Improvement:
+Feature:
 - [#1453](https://github.com/elysiajs/elysia/issues/1453) add `allowUnsafeValidationDetails` for disabling unsafe validation details in production mode
+- allow rapid stream in non browser mode or `ELYSIA_RAPID_STREAM` is set
 
 Bug fix:
-- [#1502](https://github.com/elysiajs/elysia/issues/1502) afterHandle doesn't update status
+- [#1502](https://github.com/elysiajs/elysia/issues/1502), [#1501](https://github.com/elysiajs/elysia/issues/1501) afterHandle doesn't update status
+- [#1500](https://github.com/elysiajs/elysia/issues/1500) export `InvalidFileType` from root
 - [#1495](https://github.com/elysiajs/elysia/pull/1495) request server hook parameters are typed as any (Bun 1.3.0)
 - [#1483](https://github.com/elysiajs/elysia/pull/1483) handle standard schema validators in ValidationError.all
 - [#1459](https://github.com/elysiajs/elysia/pull/1459) fix strictPath behavior when aot: false is set
 - [#1455](https://github.com/elysiajs/elysia/pull/1455) graceful shutdown not awaiting server.stop
 - [#1499](https://github.com/elysiajs/elysia/pull/1449) fails when merging with t.Optional schema
+- remove encoding chunk from native static response in Bun adapter
 
 change:
 - make `@types/bun` an optional dependency

example/a.ts

@@ -1,15 +1,7 @@
-import { Elysia, t } from '../src'
-import { req } from '../test/utils'
+import { Elysia, file } from '../src'
 
 const app = new Elysia({
 	allowUnsafeValidationDetails: true
 })
-	.onError(({ error }) => {
-		// console.log(error)
-	})
-	.get('/q', () => {}, {
-		query: t.Object({
-			a: t.String()
-		})
-	})
+	.get('/', file('test/images/aris-yuzu.jpg'))
 	.listen(3000)

package.json

@@ -1,7 +1,7 @@
 {
 	"name": "elysia",
 	"description": "Ergonomic Framework for Human",
-	"version": "1.4.12",
+	"version": "1.4.13",
 	"author": {
 		"name": "saltyAom",
 		"url": "https://github.com/SaltyAom",

src/adapter/bun/index.ts

@@ -340,13 +340,11 @@ export const BunAdapter: ElysiaAdapter = {
 									createStaticRoute(app.router.response),
 									mapRoutes(app)
 								),
-								// @ts-expect-error private property
 								app.config.serve?.routes
 							),
 							websocket: {
 								...(app.config.websocket || {}),
 								...(websocket || {}),
-								// @ts-expect-error not available in this variant of options type
 								...(options.websocket || {})
 							},
 							fetch: app.fetch
@@ -362,7 +360,6 @@ export const BunAdapter: ElysiaAdapter = {
 									createStaticRoute(app.router.response),
 									mapRoutes(app)
 								),
-								// @ts-expect-error private property
 								app.config.serve?.routes
 							),
 							websocket: {
@@ -405,7 +402,6 @@ export const BunAdapter: ElysiaAdapter = {
 							}),
 							mapRoutes(app)
 						),
-						// @ts-expect-error private property
 						app.config.serve?.routes
 					)
 				})
@@ -528,7 +524,7 @@ export const BunAdapter: ElysiaAdapter = {
 						}
 
 				if (
-					server?.upgrade<any>(context.request, {
+					server?.upgrade(context.request, {
 						headers: isNotEmpty(set.headers)
 							? (set.headers as Record<string, string>)
 							: undefined,

src/adapter/utils.ts

@@ -20,15 +20,12 @@ export const handleFile = (
 			set.status === 416)
 
 	const defaultHeader = immutable
-		? ({
-				'transfer-encoding': 'chunked'
-			} as Record<string, string>)
+		? {}
 		: ({
 				'accept-ranges': 'bytes',
 				'content-range': size
 					? `bytes 0-${size - 1}/${size}`
-					: undefined,
-				'transfer-encoding': 'chunked'
+					: undefined
 			} as Record<string, string>)
 
 	if (!set && !size) return new Response(response as Blob)
@@ -147,6 +144,8 @@ type CreateHandlerParameter = {
 	mapCompactResponse(response: unknown, request?: Request): Response
 }
 
+const allowRapidStream = process.env.ELYSIA_RAPID_STREAM === 'true'
+
 export const createStreamHandler =
 	({ mapResponse, mapCompactResponse }: CreateHandlerParameter) =>
 	async (
@@ -207,6 +206,8 @@ export const createStreamHandler =
 				}
 			}
 
+		const isBrowser = request?.headers.has('Origin')
+
 		return new Response(
 			new ReadableStream({
 				async start(controller) {
@@ -265,7 +266,7 @@ export const createStreamHandler =
 								else
 									controller.enqueue(format(chunk.toString()))
 
-								if (!isSSE)
+								if (!allowRapidStream && isBrowser && !isSSE)
 									/**
 									 * Wait for the next event loop
 									 * otherwise the data will be mixed up

src/error.ts

@@ -269,7 +269,7 @@ export class ValidationError extends Error {
 			| StandardSchemaV1Like,
 		public value: unknown,
 		private allowUnsafeValidationDetails = false,
-		errors?: ValueErrorIterator,
+		errors?: ValueErrorIterator
 	) {
 		let message = ''
 		let error
@@ -438,7 +438,9 @@ export class ValidationError extends Error {
 			'~standard' in this.validator ||
 			// @ts-ignore
 			('schema' in this.validator &&
+				// @ts-ignore
 				this.validator.schema &&
+				// @ts-ignore
 				'~standard' in this.validator.schema)
 		) {
 			const standard = // @ts-ignore

src/index.ts

@@ -8264,6 +8264,7 @@ export {
 	ParseError,
 	NotFoundError,
 	ValidationError,
+	InvalidFileType,
 	InternalServerError,
 	InvalidCookieSignature,
 	ERROR_CODE,

src/type-system/utils.ts

@@ -44,6 +44,7 @@ export const compile = <T extends TAnySchema>(schema: T) => {
 
 		compiler.Create = () => Value.Create(schema)
 		compiler.Error = (v: unknown) =>
+			// @ts-ignore
 			new ValidationError('property', schema, v, compiler.Errors(v))
 
 		return compiler
@@ -56,6 +57,7 @@ export const compile = <T extends TAnySchema>(schema: T) => {
 						'property',
 						schema,
 						v,
+						// @ts-ignore
 						Value.Errors(schema, v)
 					)
 			},
@@ -66,6 +68,7 @@ export const compile = <T extends TAnySchema>(schema: T) => {
 					'property',
 					schema,
 					v,
+					// @ts-ignore
 					Value.Errors(schema, v)
 				)
 		}
@@ -132,9 +135,7 @@ export const fileType = async (
 	name = file?.name ?? ''
 ): Promise<boolean> => {
 	if (Array.isArray(file)) {
-		await Promise.all(
-			file.map((f) => fileType(f, extension, name))
-		)
+		await Promise.all(file.map((f) => fileType(f, extension, name)))
 
 		return true
 	}