MCPcopy Create free account
hub / github.com/emilk/ehttp / fetch_streaming

Function fetch_streaming

ehttp/src/streaming/native.rs:102–110  ·  view source on GitHub ↗
(
    request: Request,
    on_data: Box<dyn Fn(crate::Result<Part>) -> ControlFlow<()> + Send>,
)

Source from the content-addressed store, hash-verified

100}
101
102pub(crate) fn fetch_streaming(
103 request: Request,
104 on_data: Box<dyn Fn(crate::Result<Part>) -> ControlFlow<()> + Send>,
105) {
106 std::thread::Builder::new()
107 .name("ehttp".to_owned())
108 .spawn(move || fetch_streaming_blocking(request, on_data))
109 .expect("Failed to spawn ehttp thread");
110}

Callers

nothing calls this directly

Calls 1

fetch_streaming_blockingFunction · 0.85

Tested by

no test coverage detected