@@ -235,48 +235,39 @@ impl Future for ReqInner {
235
235
let fstat_ptr = self . fstat . as_mut_ptr ( ) ;
236
236
237
237
match self . method {
238
- COAP_METHOD_GET => {
239
- if self . blockwise {
240
- let idx = self . blockwise_state_index . unwrap ( ) ;
241
-
242
- if BlockwiseData :: state_is_valid ( idx) {
243
- BlockwiseData :: set_state_last ( Some ( idx) ) ;
244
- BlockwiseData :: update_state ( idx,
245
- self . addr . as_bytes ( ) ,
246
- self . uri . as_bytes ( ) ,
247
- self . blockwise_hdr . as_deref ( ) ) ;
248
-
249
- gcoap_get_blockwise_inner ( & self . addr , & self . uri , idx, fstat_ptr) ;
250
- } else { // blockwise stream could be already closed
251
- BlockwiseData :: set_state_last ( None ) ;
252
-
253
- return Poll :: Ready ( GcoapMemoState :: Err )
254
- }
255
- } else {
256
- gcoap_get_inner ( & self . addr , & self . uri , fstat_ptr) ;
238
+ COAP_METHOD_GET if self . blockwise => {
239
+ let idx = self . blockwise_state_index . unwrap ( ) ;
240
+
241
+ if BlockwiseData :: state_is_valid ( idx) {
242
+ BlockwiseData :: set_state_last ( Some ( idx) ) ;
243
+ BlockwiseData :: update_state ( idx,
244
+ self . addr . as_bytes ( ) ,
245
+ self . uri . as_bytes ( ) ,
246
+ self . blockwise_hdr . as_deref ( ) ) ;
247
+
248
+ gcoap_get_blockwise_inner ( & self . addr , & self . uri , idx, fstat_ptr) ;
249
+ } else { // blockwise stream could be already closed
250
+ BlockwiseData :: set_state_last ( None ) ;
251
+ return Poll :: Ready ( GcoapMemoState :: Err )
257
252
}
258
253
} ,
254
+ COAP_METHOD_GET if !self . blockwise => gcoap_get_inner (
255
+ & self . addr , & self . uri , fstat_ptr) ,
259
256
COAP_METHOD_POST => gcoap_post_inner (
260
257
& self . addr , & self . uri , self . payload . as_ref ( ) . unwrap ( ) . as_slice ( ) , fstat_ptr) ,
261
258
COAP_METHOD_PUT => gcoap_put_inner (
262
259
& self . addr , & self . uri , self . payload . as_ref ( ) . unwrap ( ) . as_slice ( ) , fstat_ptr) ,
263
- _ => todo ! ( ) ,
260
+ _ => panic ! ( ) ,
264
261
}
265
262
266
263
Poll :: Pending
267
264
} ,
268
- FutureState :: Resolved ( _) => {
269
- Poll :: Ready ( self . fstat . take ( ) )
270
- } ,
265
+ FutureState :: Resolved ( _) => Poll :: Ready ( self . fstat . take ( ) ) ,
271
266
_ => panic ! ( ) ,
272
267
}
273
268
}
274
269
}
275
270
276
- unsafe impl Send for ReqInner {
277
- // !!!! !!!!
278
- }
279
-
280
271
//
281
272
282
273
fn gcoap_get_blockwise_inner ( addr : & str , uri : & str , blockwise_state_index : usize , fstat_ptr : * mut FutureState < GcoapMemoState > ) {
0 commit comments