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 {
107107 Ok ( new_session)
108108 }
109109
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 ) {
111111 tracing:: info!( "Attempting to perform handshake with primary." ) ;
112112 if self . dirty {
113113 self . prefetched_batch_log_entries = None ;
@@ -144,7 +144,7 @@ impl RemoteClient {
144144 frames
145145 } ;
146146
147- hello
147+ ( hello. 0 . map ( |_| ( ) ) , hello . 1 )
148148 }
149149
150150 async fn handle_next_frames_response (
@@ -255,7 +255,7 @@ impl ReplicatorClient for RemoteClient {
255255 & result,
256256 "handshake" ,
257257 ) ;
258- result. map ( |_| ( ) )
258+ result
259259 }
260260
261261 /// Return a stream of frames to apply to the database
You can’t perform that action at this time.
0 commit comments