mirror of
https://github.com/ProtonMail/go-proton-api.git
synced 2025-12-23 23:57:50 -05:00
42 lines
654 B
Go
42 lines
654 B
Go
package proton
|
|
|
|
import "context"
|
|
|
|
type job[In, Out any] struct {
|
|
ctx context.Context
|
|
req In
|
|
|
|
res chan Out
|
|
err chan error
|
|
|
|
done chan struct{}
|
|
}
|
|
|
|
func newJob[In, Out any](ctx context.Context, req In) *job[In, Out] {
|
|
return &job[In, Out]{
|
|
ctx: ctx,
|
|
req: req,
|
|
res: make(chan Out),
|
|
err: make(chan error),
|
|
done: make(chan struct{}),
|
|
}
|
|
}
|
|
|
|
func (job *job[In, Out]) Result() (Out, error) {
|
|
return <-job.res, <-job.err
|
|
}
|
|
|
|
func (job *job[In, Out]) postSuccess(res Out) {
|
|
close(job.err)
|
|
job.res <- res
|
|
}
|
|
|
|
func (job *job[In, Out]) postFailure(err error) {
|
|
close(job.res)
|
|
job.err <- err
|
|
}
|
|
|
|
func (job *job[In, Out]) waitDone() {
|
|
<-job.done
|
|
}
|