diff options
Diffstat (limited to 'weed/mq/client/agent_client/agent_subscribe.go')
| -rw-r--r-- | weed/mq/client/agent_client/agent_subscribe.go | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/weed/mq/client/agent_client/agent_subscribe.go b/weed/mq/client/agent_client/agent_subscribe.go deleted file mode 100644 index 626a3a123..000000000 --- a/weed/mq/client/agent_client/agent_subscribe.go +++ /dev/null @@ -1,17 +0,0 @@ -package agent_client - -import ( - "github.com/seaweedfs/seaweedfs/weed/pb/schema_pb" -) - -func (a *SubscribeSession) SubscribeMessageRecord( - onEachMessageFn func(key []byte, record *schema_pb.RecordValue), - onCompletionFn func()) error { - for { - resp, err := a.stream.Recv() - if err != nil { - return err - } - onEachMessageFn(resp.Key, resp.Value) - } -} |