Browse code
Fix event filters
Signed-off-by: Michael Crosby <crosbymichael@gmail.com>
Michael Crosby authored on 2017/12/05 23:55:33Showing 1 changed files
| ... | ... |
@@ -681,7 +681,10 @@ func (c *client) processEventStream(ctx context.Context) {
|
| 681 | 681 |
}() |
| 682 | 682 |
|
| 683 | 683 |
eventStream, err = c.remote.EventService().Subscribe(ctx, &eventsapi.SubscribeRequest{
|
| 684 |
- Filters: []string{"namespace==" + c.namespace + ",topic~=/tasks/.+"},
|
|
| 684 |
+ Filters: []string{
|
|
| 685 |
+ "namespace==" + c.namespace, |
|
| 686 |
+ "topic~=/tasks/", |
|
| 687 |
+ }, |
|
| 685 | 688 |
}, grpc.FailFast(false)) |
| 686 | 689 |
if err != nil {
|
| 687 | 690 |
return |