Compare commits
2 Commits
v0.0.6
...
add-keyoxi
| Author | SHA1 | Date | |
|---|---|---|---|
| bb7f6b3878 | |||
| 41476d04a2 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -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