method ResponseStream.close
Abandons or finishes the response: closing before the end of the body closes the connection (HTTP/1.1) or resets the stream (HTTP/2).
Example:
use std.http { Server, ServerConfig, ServerHandle, Router, Request, Reply, Client, Header, HttpConfig, Response, WebSocket, WsConfig, WsKind, WsMessage, SseWriter, SseStream, SseConfig, SseEvent, BodyWriter, Http2, Http2Handle, ResponseStream, chunks }
fn run() -> () | NetError | DecodeError | Panicked net, io, time {
let srv = Server.bind(ServerConfig{ port: 0, followNode: false })?
defer srv.close()
let stop = srv.handle()
let base = "http://127.0.0.1:{srv.port()}"
let router = Router.new().get("/data", (req: Request) => Reply.text("0123456789"))
scope {
spawn stop.serve(router)
let rs = Client.openStream("GET", "{base}/data")?
rs.close()
print("closed early")
stop.shutdown()
()
}?
}
fn main() io, net, time {
match run() {
NetError _ => print("net error")
DecodeError _ => print("decode error")
Panicked _ => print("panicked")
_ => {}
}
}Output
closed early
pub(api) move fn close()Since. 1.0.0-beta
Effects
none declared (pure unless the body says otherwise)
Defined in: std/http/http.oxl:5321