Commitc405958

committed

throttle

1 parent2304c0d commitc405958Copy full SHA for c405958

File tree

+37

-3

lines changed

+37

-3

lines changed

Lines changed: 8 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -129,9 +129,14 @@ public func download(`
`129`	`129`	`src:URL,`
`130`	`130`	`dest:URL,`
`131`	`131`	`urlSession:URLSession,`
`132`		`- progressUpdates:((DownloadProgress)->Void)?=nil`
	`132`	`+ progressUpdates:(@Sendable(DownloadProgress)->Void)?=nil`
`133`	`133`	`)asyncthrows(DownloadError){`
`134`		`-tryawaitDownloadManager().download(src: src, dest: dest, urlSession: urlSession, progressUpdates: progressUpdates)`
	`134`	`+tryawaitDownloadManager().download(`
	`135`	`+ src: src,`
	`136`	`+ dest: dest,`
	`137`	`+ urlSession: urlSession,`
	`138`	`+ progressUpdates: progressUpdates.flatMap{throttle(interval:.milliseconds(10), $0)},`
	`139`	`+)`
`135`	`140`	`}`
`136`	`141`
`137`	`142`	`func etag(data:Data)->String{`
`@@ -173,7 +178,7 @@ private final class DownloadManager: NSObject, @unchecked Sendable {`
`173`	`178`	`src:URL,`
`174`	`179`	`dest:URL,`
`175`	`180`	`urlSession:URLSession,`
`176`		`- progressUpdates:((DownloadProgress)->Void)?`
	`181`	`+ progressUpdates:(@Sendable(DownloadProgress)->Void)?`
`177`	`182`	`)asyncthrows(DownloadError){`
`178`	`183`	`varreq=URLRequest(url: src)`
`179`	`184`	`ifFileManager.default.fileExists(atPath: dest.path){`

Lines changed: 29 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -29,3 +29,32 @@ public func makeNSError(suffix: String, code: Int = -1, desc: String) -> NSError`
`29`	`29`	`userInfo:[NSLocalizedDescriptionKey: desc]`
`30`	`30`	`)`
`31`	`31`	`}`
	`32`	`+`
	`33`	`+privateactorThrottler<T:Sendable>{`
	`34`	`+letinterval:Duration`
	`35`	`+letsend:@Sendable(T)->Void`
	`36`	`+varlastFire:ContinuousClock.Instant?`
	`37`	`+`
	`38`	`+init(interval:Duration, send:@escaping@Sendable(T)->Void){`
	`39`	`+self.interval= interval`
	`40`	`+self.send= send`
	`41`	`+}`
	`42`	`+`
	`43`	`+func push(_ value:T){`
	`44`	`+letnow=ContinuousClock.now`
	`45`	`+iflet lastFire, now- lastFire< interval{return}`
	`46`	`+ lastFire= now`
	`47`	`+send(value)`
	`48`	`+}`
	`49`	`+}`
	`50`	`+`
	`51`	`+publicfunc throttle<T:Sendable>(`
	`52`	`+ interval:Duration,`
	`53`	`+ _ send:@escaping@Sendable(T)->Void`
	`54`	`+)->@Sendable(T)->Void{`
	`55`	`+letbox=Throttler(interval: interval, send: send)`
	`56`	`+`
	`57`	`+return{ valuein`
	`58`	`+Task{await box.push(value)}`
	`59`	`+}`
	`60`	`+}`

Comments

(0)