| 6303 | } |
| 6304 | |
| 6305 | type workerSubscribeClient struct { |
| 6306 | grpc.ClientStream |
| 6307 | } |
| 6308 | |
| 6309 | func (x *workerSubscribeClient) Recv() (*pb.KVList, error) { |
| 6310 | m := new(pb.KVList) |
nothing calls this directly
no outgoing calls
no test coverage detected