Function
_Worker_Subscribe_Handler
(srv interface{}, stream grpc.ServerStream)
Source from the content-addressed store, hash-verified
| 6582 | } |
| 6583 | |
| 6584 | func _Worker_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 6585 | m := new(SubscriptionRequest) |
| 6586 | if err := stream.RecvMsg(m); err != nil { |
| 6587 | return err |
| 6588 | } |
| 6589 | return srv.(WorkerServer).Subscribe(m, &workerSubscribeServer{stream}) |
| 6590 | } |
| 6591 | |
| 6592 | type Worker_SubscribeServer interface { |
| 6593 | Send(*pb.KVList) error |
Callers
nothing calls this directly
Tested by
no test coverage detected