Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
bb7f6b3878 | ||
|
|
41476d04a2 |
No files matched your search
@@ -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 {
|
||||
|
||||
File renamed without changes.
File renamed without changes.
File renamed without changes.
@@ -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