@@ -4114,19 +4114,22 @@ impl Application for App {
4114
4114
] ;
4115
4115
4116
4116
for ( key, mounter) in MOUNTERS . iter ( ) {
4117
- let key = * key;
4118
- subscriptions. push ( mounter. subscription ( ) . map ( move |mounter_message| {
4119
- match mounter_message {
4120
- MounterMessage :: Items ( items) => Message :: MounterItems ( key, items) ,
4121
- MounterMessage :: MountResult ( item, res) => Message :: MountResult ( key, item, res) ,
4122
- MounterMessage :: NetworkAuth ( uri, auth, auth_tx) => {
4123
- Message :: NetworkAuth ( key, uri, auth, auth_tx)
4124
- }
4125
- MounterMessage :: NetworkResult ( uri, res) => {
4126
- Message :: NetworkResult ( key, uri, res)
4127
- }
4128
- }
4129
- } ) ) ;
4117
+ subscriptions. push (
4118
+ mounter. subscription ( ) . with ( * key) . map (
4119
+ |( key, mounter_message) | match mounter_message {
4120
+ MounterMessage :: Items ( items) => Message :: MounterItems ( key, items) ,
4121
+ MounterMessage :: MountResult ( item, res) => {
4122
+ Message :: MountResult ( key, item, res)
4123
+ }
4124
+ MounterMessage :: NetworkAuth ( uri, auth, auth_tx) => {
4125
+ Message :: NetworkAuth ( key, uri, auth, auth_tx)
4126
+ }
4127
+ MounterMessage :: NetworkResult ( uri, res) => {
4128
+ Message :: NetworkResult ( key, uri, res)
4129
+ }
4130
+ } ,
4131
+ ) ,
4132
+ ) ;
4130
4133
}
4131
4134
4132
4135
if !self . pending_operations . is_empty ( ) {
0 commit comments