File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -107,7 +107,7 @@ impl RemoteClient {
107
107
Ok ( new_session)
108
108
}
109
109
110
- async fn do_handshake_with_prefetch ( & mut self ) -> ( Result < bool , Error > , Duration ) {
110
+ async fn do_handshake_with_prefetch ( & mut self ) -> ( Result < ( ) , Error > , Duration ) {
111
111
tracing:: info!( "Attempting to perform handshake with primary." ) ;
112
112
if self . dirty {
113
113
self . prefetched_batch_log_entries = None ;
@@ -144,7 +144,7 @@ impl RemoteClient {
144
144
frames
145
145
} ;
146
146
147
- hello
147
+ ( hello. 0 . map ( |_| ( ) ) , hello . 1 )
148
148
}
149
149
150
150
async fn handle_next_frames_response (
@@ -255,7 +255,7 @@ impl ReplicatorClient for RemoteClient {
255
255
& result,
256
256
"handshake" ,
257
257
) ;
258
- result. map ( |_| ( ) )
258
+ result
259
259
}
260
260
261
261
/// Return a stream of frames to apply to the database
You can’t perform that action at this time.
0 commit comments