| 6255 | } |
| 6256 | |
| 6257 | type workerReceivePredicateClient struct { |
| 6258 | grpc.ClientStream |
| 6259 | } |
| 6260 | |
| 6261 | func (x *workerReceivePredicateClient) Send(m *KVS) error { |
| 6262 | return x.ClientStream.SendMsg(m) |
nothing calls this directly
no outgoing calls
no test coverage detected