File tree Expand file tree Collapse file tree 2 files changed +3
-0
lines changed
Expand file tree Collapse file tree 2 files changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -89,6 +89,7 @@ pub async fn send_messages(
8989// Reads the WS responses
9090// Matches each response with the corresponding proof sent
9191// finishes when the last proof sent receives its response
92+ // finishes early if the batcher replies with a SubmitError
9293pub async fn receive (
9394 response_stream : Arc < Mutex < ResponseStream > > ,
9495 mut sent_verification_data_rev : Vec < Result < NoncedVerificationData , SubmitError > > ,
Original file line number Diff line number Diff line change @@ -290,6 +290,8 @@ pub fn get_aligned_service_manager_address(network: Network) -> ethers::types::H
290290 }
291291}
292292
293+ // Will submit the proofs to the batcher and wait for their responses
294+ // Will return once all proofs are responded, or up to when a proof is responded with an error
293295async fn _submit_multiple (
294296 ws_write : Arc < Mutex < SplitSink < WebSocketStream < MaybeTlsStream < TcpStream > > , Message > > > ,
295297 mut ws_read : SplitStream < WebSocketStream < MaybeTlsStream < TcpStream > > > ,
You can’t perform that action at this time.
0 commit comments