(srv interface{}, stream grpc.ServerStream)
| 6422 | } |
| 6423 | |
| 6424 | func _Worker_StreamSnapshot_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 6425 | return srv.(WorkerServer).StreamSnapshot(&workerStreamSnapshotServer{stream}) |
| 6426 | } |
| 6427 | |
| 6428 | type Worker_StreamSnapshotServer interface { |
| 6429 | Send(*KVS) error |
nothing calls this directly
no test coverage detected