Function
_Downstream_Changes_Handler
(srv interface{}, stream grpc.ServerStream)
Source from the content-addressed store, hash-verified
| 339 | } |
| 340 | |
| 341 | func _Downstream_Changes_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 342 | m := new(Empty) |
| 343 | if err := stream.RecvMsg(m); err != nil { |
| 344 | return err |
| 345 | } |
| 346 | return srv.(DownstreamServer).Changes(m, &downstreamChangesServer{stream}) |
| 347 | } |
| 348 | |
| 349 | type Downstream_ChangesServer interface { |
| 350 | Send(*ChangeChunk) error |
Callers
nothing calls this directly
Tested by
no test coverage detected