This repository was archived by the owner on Aug 28, 2024. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -297,7 +297,10 @@ pub(crate) async fn register_service() {
297
297
}
298
298
}
299
299
Message :: Binary ( s) => {
300
- if s. starts_with ( & TAG_SOME_DATA_START ) {
300
+ if s. starts_with ( & TAG_NONE_DATA_START ) {
301
+ let id = String :: from_utf8 ( s[ 14 ..46 ] . to_vec ( ) ) . unwrap ( ) ;
302
+ trace ! ( "二进制响应体结束 TAG_NONE_DATA_START, {}" , id) ;
303
+ } else {
301
304
let id = String :: from_utf8 ( s[ 14 ..46 ] . to_vec ( ) ) . unwrap ( ) ;
302
305
let mut body = BytesMut :: from ( s. as_slice ( ) ) ;
303
306
let index = binary_search ( & s, & TAG_BODY_SPLIT ) . unwrap ( ) ;
@@ -316,12 +319,12 @@ pub(crate) async fn register_service() {
316
319
drop ( cache) ;
317
320
// unsafe { Arc::get_mut_unchecked(&mut MS_TTS_DATA_CACHE.clone()).get_mut(&id).unwrap().lock().await.data.put(body) };
318
321
trace ! ( "二进制响应体 ,{}" , id) ;
319
- } else if s . starts_with ( & TAG_NONE_DATA_START ) {
320
- let id = String :: from_utf8 ( s [ 14 .. 46 ] . to_vec ( ) ) . unwrap ( ) ;
321
- trace ! ( "二进制响应体结束 TAG_NONE_DATA_START, {}" , id ) ;
322
- } else {
322
+
323
+
324
+
325
+ } /* else {
323
326
trace!("其他二进制类型: {} ", unsafe { String::from_utf8_unchecked(s.to_vec()) });
324
- }
327
+ }*/
325
328
}
326
329
_ => { }
327
330
}
You can’t perform that action at this time.
0 commit comments