| // This file is automatically generated, so please do not edit it. |
| // @generated by `flutter_rust_bridge`@ 2.8.0. |
| |
| #![allow( |
| non_camel_case_types, |
| unused, |
| non_snake_case, |
| clippy::needless_return, |
| clippy::redundant_closure_call, |
| clippy::redundant_closure, |
| clippy::useless_conversion, |
| clippy::unit_arg, |
| clippy::unused_unit, |
| clippy::double_parens, |
| clippy::let_and_return, |
| clippy::too_many_arguments, |
| clippy::match_single_binding, |
| clippy::clone_on_copy, |
| clippy::let_unit_value, |
| clippy::deref_addrof, |
| clippy::explicit_auto_deref, |
| clippy::borrow_deref_ref, |
| clippy::needless_borrow |
| )] |
| |
| // Section: imports |
| |
| use crate::api::opendal_api::*; |
| use flutter_rust_bridge::for_generated::byteorder::{NativeEndian, ReadBytesExt, WriteBytesExt}; |
| use flutter_rust_bridge::for_generated::{transform_result_dco, Lifetimeable, Lockable}; |
| use flutter_rust_bridge::{Handler, IntoIntoDart}; |
| |
| // Section: boilerplate |
| |
| flutter_rust_bridge::frb_generated_boilerplate!( |
| default_stream_sink_codec = SseCodec, |
| default_rust_opaque = RustOpaqueMoi, |
| default_rust_auto_opaque = RustAutoOpaqueMoi, |
| ); |
| pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_VERSION: &str = "2.8.0"; |
| pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_CONTENT_HASH: i32 = 775125233; |
| |
| // Section: executor |
| |
| flutter_rust_bridge::frb_generated_default_handler!(); |
| |
| // Section: wire_funcs |
| |
| fn wire__crate__api__opendal_api__Metadata_content_disposition_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_content_disposition", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Metadata::content_disposition(&*api_that_guard), |
| )?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Metadata_content_length_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_content_length", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Metadata::content_length(&*api_that_guard), |
| )?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Metadata_content_md5_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_content_md5", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Metadata::content_md5(&*api_that_guard), |
| )?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Metadata_content_type_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_content_type", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Metadata::content_type(&*api_that_guard), |
| )?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Metadata_etag_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_etag", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = |
| Result::<_, ()>::Ok(crate::api::opendal_api::Metadata::etag(&*api_that_guard))?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Metadata_is_directory_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_is_directory", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Metadata::is_directory(&*api_that_guard), |
| )?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Metadata_is_file_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_is_file", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok(crate::api::opendal_api::Metadata::is_file( |
| &*api_that_guard, |
| ))?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Metadata_last_modified_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Metadata_last_modified", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Metadata::last_modified(&*api_that_guard), |
| )?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_check_impl( |
| port_: flutter_rust_bridge::for_generated::MessagePort, |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_check", |
| port: Some(port_), |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| move |context| async move { |
| transform_result_sse::<_, ()>( |
| (move || async move { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order( |
| vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| )], |
| ); |
| for i in decode_indices_ { |
| match i { |
| 0 => { |
| api_that_guard = |
| Some(api_that.lockable_decode_async_ref().await) |
| } |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok({ |
| crate::api::opendal_api::Operator::check(&*api_that_guard).await; |
| })?; |
| Ok(output_ok) |
| })() |
| .await, |
| ) |
| } |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_create_dir_impl( |
| port_: flutter_rust_bridge::for_generated::MessagePort, |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_create_dir", |
| port: Some(port_), |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| move |context| async move { |
| transform_result_sse::<_, ()>( |
| (move || async move { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order( |
| vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| )], |
| ); |
| for i in decode_indices_ { |
| match i { |
| 0 => { |
| api_that_guard = |
| Some(api_that.lockable_decode_async_ref().await) |
| } |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok({ |
| crate::api::opendal_api::Operator::create_dir( |
| &*api_that_guard, |
| api_path, |
| ) |
| .await; |
| })?; |
| Ok(output_ok) |
| })() |
| .await, |
| ) |
| } |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_create_dir_sync_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_create_dir_sync", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok({ |
| crate::api::opendal_api::Operator::create_dir_sync(&*api_that_guard, api_path); |
| })?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_delete_impl( |
| port_: flutter_rust_bridge::for_generated::MessagePort, |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_delete", |
| port: Some(port_), |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| move |context| async move { |
| transform_result_sse::<_, ()>( |
| (move || async move { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order( |
| vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| )], |
| ); |
| for i in decode_indices_ { |
| match i { |
| 0 => { |
| api_that_guard = |
| Some(api_that.lockable_decode_async_ref().await) |
| } |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok({ |
| crate::api::opendal_api::Operator::delete(&*api_that_guard, api_path) |
| .await; |
| })?; |
| Ok(output_ok) |
| })() |
| .await, |
| ) |
| } |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_delete_sync_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_delete_sync", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok({ |
| crate::api::opendal_api::Operator::delete_sync(&*api_that_guard, api_path); |
| })?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_exists_impl( |
| port_: flutter_rust_bridge::for_generated::MessagePort, |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_exists", |
| port: Some(port_), |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| move |context| async move { |
| transform_result_sse::<_, ()>( |
| (move || async move { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order( |
| vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| )], |
| ); |
| for i in decode_indices_ { |
| match i { |
| 0 => { |
| api_that_guard = |
| Some(api_that.lockable_decode_async_ref().await) |
| } |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Operator::exists(&*api_that_guard, api_path) |
| .await, |
| )?; |
| Ok(output_ok) |
| })() |
| .await, |
| ) |
| } |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_exists_sync_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_exists_sync", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Operator::exists_sync(&*api_that_guard, api_path), |
| )?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_new_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_new", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_scheme_str = <String>::sse_decode(&mut deserializer); |
| let api_map = |
| <std::collections::HashMap<String, String>>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let output_ok = Result::<_, ()>::Ok(crate::api::opendal_api::Operator::new( |
| api_scheme_str, |
| api_map, |
| ))?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_rename_impl( |
| port_: flutter_rust_bridge::for_generated::MessagePort, |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_rename", |
| port: Some(port_), |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_from = <String>::sse_decode(&mut deserializer); |
| let api_to = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| move |context| async move { |
| transform_result_sse::<_, ()>( |
| (move || async move { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order( |
| vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| )], |
| ); |
| for i in decode_indices_ { |
| match i { |
| 0 => { |
| api_that_guard = |
| Some(api_that.lockable_decode_async_ref().await) |
| } |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok({ |
| crate::api::opendal_api::Operator::rename( |
| &*api_that_guard, |
| api_from, |
| api_to, |
| ) |
| .await; |
| })?; |
| Ok(output_ok) |
| })() |
| .await, |
| ) |
| } |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_rename_sync_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_rename_sync", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_from = <String>::sse_decode(&mut deserializer); |
| let api_to = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok({ |
| crate::api::opendal_api::Operator::rename_sync( |
| &*api_that_guard, |
| api_from, |
| api_to, |
| ); |
| })?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_stat_impl( |
| port_: flutter_rust_bridge::for_generated::MessagePort, |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_stat", |
| port: Some(port_), |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| move |context| async move { |
| transform_result_sse::<_, ()>( |
| (move || async move { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order( |
| vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| )], |
| ); |
| for i in decode_indices_ { |
| match i { |
| 0 => { |
| api_that_guard = |
| Some(api_that.lockable_decode_async_ref().await) |
| } |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok( |
| crate::api::opendal_api::Operator::stat(&*api_that_guard, api_path) |
| .await, |
| )?; |
| Ok(output_ok) |
| })() |
| .await, |
| ) |
| } |
| }, |
| ) |
| } |
| fn wire__crate__api__opendal_api__Operator_stat_sync_impl( |
| ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len_: i32, |
| data_len_: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>( |
| flutter_rust_bridge::for_generated::TaskInfo { |
| debug_name: "Operator_stat_sync", |
| port: None, |
| mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync, |
| }, |
| move || { |
| let message = unsafe { |
| flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire( |
| ptr_, |
| rust_vec_len_, |
| data_len_, |
| ) |
| }; |
| let mut deserializer = |
| flutter_rust_bridge::for_generated::SseDeserializer::new(message); |
| let api_that = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(&mut deserializer); |
| let api_path = <String>::sse_decode(&mut deserializer); |
| deserializer.end(); |
| transform_result_sse::<_, ()>((move || { |
| let mut api_that_guard = None; |
| let decode_indices_ = |
| flutter_rust_bridge::for_generated::lockable_compute_decode_order(vec![ |
| flutter_rust_bridge::for_generated::LockableOrderInfo::new( |
| &api_that, 0, false, |
| ), |
| ]); |
| for i in decode_indices_ { |
| match i { |
| 0 => api_that_guard = Some(api_that.lockable_decode_sync_ref()), |
| _ => unreachable!(), |
| } |
| } |
| let api_that_guard = api_that_guard.unwrap(); |
| let output_ok = Result::<_, ()>::Ok(crate::api::opendal_api::Operator::stat_sync( |
| &*api_that_guard, |
| api_path, |
| ))?; |
| Ok(output_ok) |
| })()) |
| }, |
| ) |
| } |
| |
| // Section: related_funcs |
| |
| flutter_rust_bridge::frb_generated_moi_arc_impl_value!( |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata> |
| ); |
| flutter_rust_bridge::frb_generated_moi_arc_impl_value!( |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator> |
| ); |
| |
| // Section: dart2rust |
| |
| impl SseDecode for Metadata { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut inner = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>, |
| >>::sse_decode(deserializer); |
| return flutter_rust_bridge::for_generated::rust_auto_opaque_decode_owned(inner); |
| } |
| } |
| |
| impl SseDecode for Operator { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut inner = <RustOpaqueMoi< |
| flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>, |
| >>::sse_decode(deserializer); |
| return flutter_rust_bridge::for_generated::rust_auto_opaque_decode_owned(inner); |
| } |
| } |
| |
| impl SseDecode for std::collections::HashMap<String, String> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut inner = <Vec<(String, String)>>::sse_decode(deserializer); |
| return inner.into_iter().collect(); |
| } |
| } |
| |
| impl SseDecode |
| for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>> |
| { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut inner = <usize>::sse_decode(deserializer); |
| return decode_rust_opaque_moi(inner); |
| } |
| } |
| |
| impl SseDecode |
| for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>> |
| { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut inner = <usize>::sse_decode(deserializer); |
| return decode_rust_opaque_moi(inner); |
| } |
| } |
| |
| impl SseDecode for String { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut inner = <Vec<u8>>::sse_decode(deserializer); |
| return String::from_utf8(inner).unwrap(); |
| } |
| } |
| |
| impl SseDecode for bool { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| deserializer.cursor.read_u8().unwrap() != 0 |
| } |
| } |
| |
| impl SseDecode for Vec<u8> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut len_ = <i32>::sse_decode(deserializer); |
| let mut ans_ = vec![]; |
| for idx_ in 0..len_ { |
| ans_.push(<u8>::sse_decode(deserializer)); |
| } |
| return ans_; |
| } |
| } |
| |
| impl SseDecode for Vec<(String, String)> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut len_ = <i32>::sse_decode(deserializer); |
| let mut ans_ = vec![]; |
| for idx_ in 0..len_ { |
| ans_.push(<(String, String)>::sse_decode(deserializer)); |
| } |
| return ans_; |
| } |
| } |
| |
| impl SseDecode for Option<String> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| if (<bool>::sse_decode(deserializer)) { |
| return Some(<String>::sse_decode(deserializer)); |
| } else { |
| return None; |
| } |
| } |
| } |
| |
| impl SseDecode for Option<u64> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| if (<bool>::sse_decode(deserializer)) { |
| return Some(<u64>::sse_decode(deserializer)); |
| } else { |
| return None; |
| } |
| } |
| } |
| |
| impl SseDecode for (String, String) { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| let mut var_field0 = <String>::sse_decode(deserializer); |
| let mut var_field1 = <String>::sse_decode(deserializer); |
| return (var_field0, var_field1); |
| } |
| } |
| |
| impl SseDecode for u64 { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| deserializer.cursor.read_u64::<NativeEndian>().unwrap() |
| } |
| } |
| |
| impl SseDecode for u8 { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| deserializer.cursor.read_u8().unwrap() |
| } |
| } |
| |
| impl SseDecode for () { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {} |
| } |
| |
| impl SseDecode for usize { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| deserializer.cursor.read_u64::<NativeEndian>().unwrap() as _ |
| } |
| } |
| |
| impl SseDecode for i32 { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { |
| deserializer.cursor.read_i32::<NativeEndian>().unwrap() |
| } |
| } |
| |
| fn pde_ffi_dispatcher_primary_impl( |
| func_id: i32, |
| port: flutter_rust_bridge::for_generated::MessagePort, |
| ptr: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len: i32, |
| data_len: i32, |
| ) { |
| // Codec=Pde (Serialization + dispatch), see doc to use other codecs |
| match func_id { |
| 9 => wire__crate__api__opendal_api__Operator_check_impl(port, ptr, rust_vec_len, data_len), |
| 10 => wire__crate__api__opendal_api__Operator_create_dir_impl( |
| port, |
| ptr, |
| rust_vec_len, |
| data_len, |
| ), |
| 12 => { |
| wire__crate__api__opendal_api__Operator_delete_impl(port, ptr, rust_vec_len, data_len) |
| } |
| 14 => { |
| wire__crate__api__opendal_api__Operator_exists_impl(port, ptr, rust_vec_len, data_len) |
| } |
| 17 => { |
| wire__crate__api__opendal_api__Operator_rename_impl(port, ptr, rust_vec_len, data_len) |
| } |
| 19 => wire__crate__api__opendal_api__Operator_stat_impl(port, ptr, rust_vec_len, data_len), |
| _ => unreachable!(), |
| } |
| } |
| |
| fn pde_ffi_dispatcher_sync_impl( |
| func_id: i32, |
| ptr: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr, |
| rust_vec_len: i32, |
| data_len: i32, |
| ) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse { |
| // Codec=Pde (Serialization + dispatch), see doc to use other codecs |
| match func_id { |
| 1 => wire__crate__api__opendal_api__Metadata_content_disposition_impl( |
| ptr, |
| rust_vec_len, |
| data_len, |
| ), |
| 2 => { |
| wire__crate__api__opendal_api__Metadata_content_length_impl(ptr, rust_vec_len, data_len) |
| } |
| 3 => wire__crate__api__opendal_api__Metadata_content_md5_impl(ptr, rust_vec_len, data_len), |
| 4 => wire__crate__api__opendal_api__Metadata_content_type_impl(ptr, rust_vec_len, data_len), |
| 5 => wire__crate__api__opendal_api__Metadata_etag_impl(ptr, rust_vec_len, data_len), |
| 6 => wire__crate__api__opendal_api__Metadata_is_directory_impl(ptr, rust_vec_len, data_len), |
| 7 => wire__crate__api__opendal_api__Metadata_is_file_impl(ptr, rust_vec_len, data_len), |
| 8 => { |
| wire__crate__api__opendal_api__Metadata_last_modified_impl(ptr, rust_vec_len, data_len) |
| } |
| 11 => wire__crate__api__opendal_api__Operator_create_dir_sync_impl( |
| ptr, |
| rust_vec_len, |
| data_len, |
| ), |
| 13 => wire__crate__api__opendal_api__Operator_delete_sync_impl(ptr, rust_vec_len, data_len), |
| 15 => wire__crate__api__opendal_api__Operator_exists_sync_impl(ptr, rust_vec_len, data_len), |
| 16 => wire__crate__api__opendal_api__Operator_new_impl(ptr, rust_vec_len, data_len), |
| 18 => wire__crate__api__opendal_api__Operator_rename_sync_impl(ptr, rust_vec_len, data_len), |
| 20 => wire__crate__api__opendal_api__Operator_stat_sync_impl(ptr, rust_vec_len, data_len), |
| _ => unreachable!(), |
| } |
| } |
| |
| // Section: rust2dart |
| |
| // Codec=Dco (DartCObject based), see doc to use other codecs |
| impl flutter_rust_bridge::IntoDart for FrbWrapper<Metadata> { |
| fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi { |
| flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self.0) |
| .into_dart() |
| } |
| } |
| impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for FrbWrapper<Metadata> {} |
| |
| impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<Metadata>> for Metadata { |
| fn into_into_dart(self) -> FrbWrapper<Metadata> { |
| self.into() |
| } |
| } |
| |
| // Codec=Dco (DartCObject based), see doc to use other codecs |
| impl flutter_rust_bridge::IntoDart for FrbWrapper<Operator> { |
| fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi { |
| flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self.0) |
| .into_dart() |
| } |
| } |
| impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for FrbWrapper<Operator> {} |
| |
| impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<Operator>> for Operator { |
| fn into_into_dart(self) -> FrbWrapper<Operator> { |
| self.into() |
| } |
| } |
| |
| impl SseEncode for Metadata { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>>>::sse_encode(flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self), serializer); |
| } |
| } |
| |
| impl SseEncode for Operator { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>>>::sse_encode(flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self), serializer); |
| } |
| } |
| |
| impl SseEncode for std::collections::HashMap<String, String> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <Vec<(String, String)>>::sse_encode(self.into_iter().collect(), serializer); |
| } |
| } |
| |
| impl SseEncode |
| for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>> |
| { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| let (ptr, size) = self.sse_encode_raw(); |
| <usize>::sse_encode(ptr, serializer); |
| <i32>::sse_encode(size, serializer); |
| } |
| } |
| |
| impl SseEncode |
| for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>> |
| { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| let (ptr, size) = self.sse_encode_raw(); |
| <usize>::sse_encode(ptr, serializer); |
| <i32>::sse_encode(size, serializer); |
| } |
| } |
| |
| impl SseEncode for String { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <Vec<u8>>::sse_encode(self.into_bytes(), serializer); |
| } |
| } |
| |
| impl SseEncode for bool { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| serializer.cursor.write_u8(self as _).unwrap(); |
| } |
| } |
| |
| impl SseEncode for Vec<u8> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <i32>::sse_encode(self.len() as _, serializer); |
| for item in self { |
| <u8>::sse_encode(item, serializer); |
| } |
| } |
| } |
| |
| impl SseEncode for Vec<(String, String)> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <i32>::sse_encode(self.len() as _, serializer); |
| for item in self { |
| <(String, String)>::sse_encode(item, serializer); |
| } |
| } |
| } |
| |
| impl SseEncode for Option<String> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <bool>::sse_encode(self.is_some(), serializer); |
| if let Some(value) = self { |
| <String>::sse_encode(value, serializer); |
| } |
| } |
| } |
| |
| impl SseEncode for Option<u64> { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <bool>::sse_encode(self.is_some(), serializer); |
| if let Some(value) = self { |
| <u64>::sse_encode(value, serializer); |
| } |
| } |
| } |
| |
| impl SseEncode for (String, String) { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| <String>::sse_encode(self.0, serializer); |
| <String>::sse_encode(self.1, serializer); |
| } |
| } |
| |
| impl SseEncode for u64 { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| serializer.cursor.write_u64::<NativeEndian>(self).unwrap(); |
| } |
| } |
| |
| impl SseEncode for u8 { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| serializer.cursor.write_u8(self).unwrap(); |
| } |
| } |
| |
| impl SseEncode for () { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {} |
| } |
| |
| impl SseEncode for usize { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| serializer |
| .cursor |
| .write_u64::<NativeEndian>(self as _) |
| .unwrap(); |
| } |
| } |
| |
| impl SseEncode for i32 { |
| // Codec=Sse (Serialization based), see doc to use other codecs |
| fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { |
| serializer.cursor.write_i32::<NativeEndian>(self).unwrap(); |
| } |
| } |
| |
| #[cfg(not(target_family = "wasm"))] |
| mod io { |
| // This file is automatically generated, so please do not edit it. |
| // @generated by `flutter_rust_bridge`@ 2.8.0. |
| |
| // Section: imports |
| |
| use super::*; |
| use crate::api::opendal_api::*; |
| use flutter_rust_bridge::for_generated::byteorder::{ |
| NativeEndian, ReadBytesExt, WriteBytesExt, |
| }; |
| use flutter_rust_bridge::for_generated::{transform_result_dco, Lifetimeable, Lockable}; |
| use flutter_rust_bridge::{Handler, IntoIntoDart}; |
| |
| // Section: boilerplate |
| |
| flutter_rust_bridge::frb_generated_boilerplate_io!(); |
| |
| #[unsafe(no_mangle)] |
| pub extern "C" fn frbgen_opendal_rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerMetadata( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>>::increment_strong_count(ptr as _); |
| } |
| |
| #[unsafe(no_mangle)] |
| pub extern "C" fn frbgen_opendal_rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerMetadata( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>>::decrement_strong_count(ptr as _); |
| } |
| |
| #[unsafe(no_mangle)] |
| pub extern "C" fn frbgen_opendal_rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerOperator( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>>::increment_strong_count(ptr as _); |
| } |
| |
| #[unsafe(no_mangle)] |
| pub extern "C" fn frbgen_opendal_rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerOperator( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>>::decrement_strong_count(ptr as _); |
| } |
| } |
| #[cfg(not(target_family = "wasm"))] |
| pub use io::*; |
| |
| /// cbindgen:ignore |
| #[cfg(target_family = "wasm")] |
| mod web { |
| // This file is automatically generated, so please do not edit it. |
| // @generated by `flutter_rust_bridge`@ 2.8.0. |
| |
| // Section: imports |
| |
| use super::*; |
| use crate::api::opendal_api::*; |
| use flutter_rust_bridge::for_generated::byteorder::{ |
| NativeEndian, ReadBytesExt, WriteBytesExt, |
| }; |
| use flutter_rust_bridge::for_generated::wasm_bindgen; |
| use flutter_rust_bridge::for_generated::wasm_bindgen::prelude::*; |
| use flutter_rust_bridge::for_generated::{transform_result_dco, Lifetimeable, Lockable}; |
| use flutter_rust_bridge::{Handler, IntoIntoDart}; |
| |
| // Section: boilerplate |
| |
| flutter_rust_bridge::frb_generated_boilerplate_web!(); |
| |
| #[wasm_bindgen] |
| pub fn rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerMetadata( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>>::increment_strong_count(ptr as _); |
| } |
| |
| #[wasm_bindgen] |
| pub fn rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerMetadata( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>>::decrement_strong_count(ptr as _); |
| } |
| |
| #[wasm_bindgen] |
| pub fn rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerOperator( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>>::increment_strong_count(ptr as _); |
| } |
| |
| #[wasm_bindgen] |
| pub fn rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerOperator( |
| ptr: *const std::ffi::c_void, |
| ) { |
| MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Operator>>::decrement_strong_count(ptr as _); |
| } |
| } |
| #[cfg(target_family = "wasm")] |
| pub use web::*; |
