MCPcopy
hub / github.com/SurgeDM/Surge / Flush

Method Flush

internal/engine/single/downloader.go:275–277  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

273}
274
275func (w *progressReader) Flush() {
276 w.flushWithTime(time.Now())
277}
278
279func (w *progressReader) flushWithTime(now time.Time) {
280 if w.state == nil {

Callers 7

TestLocalDownloadService_BatchProgressFunction · 0.80
TestRemoteDownloadService_StreamEvents_CleanupClosesChannelFunction · 0.80
TestRemoteDownloadService_StreamEvents_ShutdownClosesChannelFunction · 0.80
DownloadMethod · 0.80
TestProbeServer_ReadsBodyBeforeContextCancelFunction · 0.80
printDownloadsFunction · 0.80
eventsHandlerFunction · 0.80

Calls 1

flushWithTimeMethod · 0.95

Tested by 4

TestLocalDownloadService_BatchProgressFunction · 0.64
TestRemoteDownloadService_StreamEvents_CleanupClosesChannelFunction · 0.64
TestRemoteDownloadService_StreamEvents_ShutdownClosesChannelFunction · 0.64
TestProbeServer_ReadsBodyBeforeContextCancelFunction · 0.64