summaryrefslogtreecommitdiff
path: root/http/server.ts
diff options
context:
space:
mode:
authorYoshiya Hinosawa <stibium121@gmail.com>2019-03-12 14:51:51 +0900
committerRyan Dahl <ry@tinyclouds.org>2019-03-12 01:51:51 -0400
commitf124e645263099132025256df8594ca0dc5cc83a (patch)
tree07f0f99b99e55f431f71f4463aa912ab96405f61 /http/server.ts
parent4a97a6e67e93cdbcecde3d9b99092f15d3dfd803 (diff)
fix: eslint errors (denoland/deno_std#265)
Original: https://github.com/denoland/deno_std/commit/61af419bbc5717c2e2552050aacb20ef1b17480b
Diffstat (limited to 'http/server.ts')
-rw-r--r--http/server.ts24
1 files changed, 15 insertions, 9 deletions
diff --git a/http/server.ts b/http/server.ts
index 5cf658cf3..17295f739 100644
--- a/http/server.ts
+++ b/http/server.ts
@@ -36,7 +36,7 @@ export function setContentLength(r: Response): void {
}
}
}
-async function writeChunkedBody(w: Writer, r: Reader) {
+async function writeChunkedBody(w: Writer, r: Reader): Promise<void> {
const writer = bufWriter(w);
const encoder = new TextEncoder();
@@ -123,7 +123,7 @@ export class ServerRequest {
r: BufReader;
w: BufWriter;
- public async *bodyStream() {
+ public async *bodyStream(): AsyncIterableIterator<Uint8Array> {
if (this.headers.has("content-length")) {
const len = +this.headers.get("content-length");
if (Number.isNaN(len)) {
@@ -263,7 +263,11 @@ async function readRequest(
return [req, err];
}
-function maybeHandleReq(env: ServeEnv, conn: Conn, maybeReq: any) {
+function maybeHandleReq(
+ env: ServeEnv,
+ conn: Conn,
+ maybeReq: [ServerRequest, BufState]
+): void {
const [req, _err] = maybeReq;
if (_err) {
conn.close(); // assume EOF for now...
@@ -273,11 +277,13 @@ function maybeHandleReq(env: ServeEnv, conn: Conn, maybeReq: any) {
env.serveDeferred.resolve(); // signal while loop to process it
}
-function serveConn(env: ServeEnv, conn: Conn, bufr?: BufReader) {
+function serveConn(env: ServeEnv, conn: Conn, bufr?: BufReader): void {
readRequest(conn, bufr).then(maybeHandleReq.bind(null, env, conn));
}
-export async function* serve(addr: string) {
+export async function* serve(
+ addr: string
+): AsyncIterableIterator<ServerRequest> {
const listener = listen("tcp", addr);
const env: ServeEnv = {
reqQueue: [], // in case multiple promises are ready
@@ -285,9 +291,9 @@ export async function* serve(addr: string) {
};
// Routine that keeps calling accept
- let handleConn = (_conn: Conn) => {};
- let scheduleAccept = () => {};
- const acceptRoutine = () => {
+ let handleConn = (_conn: Conn): void => {};
+ let scheduleAccept = (): void => {};
+ const acceptRoutine = (): void => {
scheduleAccept = () => {
listener.accept().then(handleConn);
};
@@ -320,7 +326,7 @@ export async function* serve(addr: string) {
export async function listenAndServe(
addr: string,
handler: (req: ServerRequest) => void
-) {
+): Promise<void> {
const server = serve(addr);
for await (const request of server) {