File tree Expand file tree Collapse file tree 3 files changed +25
-17
lines changed
Expand file tree Collapse file tree 3 files changed +25
-17
lines changed Original file line number Diff line number Diff line change 44 push :
55 branches :
66 - main
7- pull_request :
8- branches :
9- - main
7+ - test
108
119env :
1210 CARGO_TERM_COLOR : always
Original file line number Diff line number Diff line change @@ -78,7 +78,8 @@ impl ReadyToReceiveBubble {
7878 pub fn unsubscribe ( & self , subscriber : Arc < dyn ReadyToReceiveSubscriber > ) {
7979 let adapted_subscriber =
8080 ReadyToReceiveSubscriberAdapter { inner : subscriber } ;
81- self . inner . unsubscribe ( Arc :: new ( adapted_subscriber) )
81+ self . inner
82+ . unsubscribe ( Arc :: new ( adapted_subscriber) )
8283 }
8384}
8485
@@ -210,11 +211,18 @@ fn create_adapted_request(
210211 avatar_b64 : request. profile . avatar_b64 ,
211212 } ;
212213 let config = match request. config {
213- Some ( config) => arkdropx_receiver:: ready_to_receive:: ReadyToReceiveConfig {
214- chunk_size : config. chunk_size ,
215- parallel_streams : config. parallel_streams ,
216- } ,
217- None => arkdropx_receiver:: ready_to_receive:: ReadyToReceiveConfig :: default ( ) ,
214+ Some ( config) => {
215+ arkdropx_receiver:: ready_to_receive:: ReadyToReceiveConfig {
216+ chunk_size : config. chunk_size ,
217+ parallel_streams : config. parallel_streams ,
218+ }
219+ }
220+ None => {
221+ arkdropx_receiver:: ready_to_receive:: ReadyToReceiveConfig :: default ( )
222+ }
218223 } ;
219- arkdropx_receiver:: ready_to_receive:: ReadyToReceiveRequest { profile, config }
224+ arkdropx_receiver:: ready_to_receive:: ReadyToReceiveRequest {
225+ profile,
226+ config,
227+ }
220228}
Original file line number Diff line number Diff line change @@ -68,7 +68,8 @@ impl SendFilesToBubble {
6868 pub fn unsubscribe ( & self , subscriber : Arc < dyn SendFilesToSubscriber > ) {
6969 let adapted_subscriber =
7070 SendFilesToSubscriberAdapter { inner : subscriber } ;
71- self . inner . unsubscribe ( Arc :: new ( adapted_subscriber) )
71+ self . inner
72+ . unsubscribe ( Arc :: new ( adapted_subscriber) )
7273 }
7374}
7475
@@ -126,12 +127,13 @@ impl arkdropx_sender::send_files_to::SendFilesToSubscriber
126127 & self ,
127128 event : arkdropx_sender:: send_files_to:: SendFilesToSendingEvent ,
128129 ) {
129- self . inner . notify_sending ( SendFilesToSendingEvent {
130- id : event. id ,
131- name : event. name ,
132- sent : event. sent ,
133- remaining : event. remaining ,
134- } )
130+ self . inner
131+ . notify_sending ( SendFilesToSendingEvent {
132+ id : event. id ,
133+ name : event. name ,
134+ sent : event. sent ,
135+ remaining : event. remaining ,
136+ } )
135137 }
136138
137139 fn notify_connecting (
You can’t perform that action at this time.
0 commit comments