Function
_StreamingQuerier_Search_Handler
(srv interface{}, stream grpc.ServerStream)
Source from the content-addressed store, hash-verified
| 3774 | } |
| 3775 | |
| 3776 | func _StreamingQuerier_Search_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 3777 | m := new(SearchRequest) |
| 3778 | if err := stream.RecvMsg(m); err != nil { |
| 3779 | return err |
| 3780 | } |
| 3781 | return srv.(StreamingQuerierServer).Search(m, &streamingQuerierSearchServer{stream}) |
| 3782 | } |
| 3783 | |
| 3784 | type StreamingQuerier_SearchServer interface { |
| 3785 | Send(*SearchResponse) error |
Callers
nothing calls this directly
Tested by
no test coverage detected