Compare commits
2 Commits
v0.0.6
...
add-keyoxide
| Author | SHA1 | Date | |
|---|---|---|---|
| bb7f6b3878 | |||
| 41476d04a2 |
@@ -1 +1,2 @@
|
||||
tools
|
||||
tmp
|
||||
|
||||
@@ -91,17 +91,17 @@ func (s *service) Run(ctx context.Context) (err error) {
|
||||
subRes, e := s.es.EventStream().Subscribe(ctx, queueResults, 0)
|
||||
errs = multierr.Append(errs, e)
|
||||
|
||||
if errs != nil {
|
||||
return errs
|
||||
}
|
||||
|
||||
defer func() {
|
||||
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
|
||||
defer cancel()
|
||||
|
||||
err = multierr.Combine(errs, subReq.Close(ctx), subRes.Close(ctx))
|
||||
err = multierr.Combine(err, subReq.Close(ctx), subRes.Close(ctx))
|
||||
}()
|
||||
|
||||
if errs != nil {
|
||||
return errs
|
||||
}
|
||||
|
||||
for {
|
||||
var events event.Events
|
||||
select {
|
||||
|
||||
@@ -1 +0,0 @@
|
||||
exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1exit status 1
|
||||
Reference in New Issue
Block a user