Currently compute_prf_for_inputs for the hybrid protocol returns a Result<Vec<_>, Error>. The function itself is async already, so we should be able to update it to return a Result<TryStream<_>>. This will then allow us to use the existing reshard_try_stream function that exists, and start resharding reports immediately after OPRF is computed, rather than waiting for all of them.
cc @akoshelev
Currently
compute_prf_for_inputsfor the hybrid protocol returns aResult<Vec<_>, Error>. The function itself isasyncalready, so we should be able to update it to return aResult<TryStream<_>>. This will then allow us to use the existingreshard_try_streamfunction that exists, and start resharding reports immediately after OPRF is computed, rather than waiting for all of them.cc @akoshelev