@@ -530,7 +530,10 @@ fn operator_delete_async_inner(
530530
531531 let op = op. clone ( ) ;
532532 executor. spawn ( async move {
533- let result = op. delete ( & path) . await . map_err ( OpenDALError :: from_opendal_error) ;
533+ let result = op
534+ . delete ( & path)
535+ . await
536+ . map_err ( OpenDALError :: from_opendal_error) ;
534537
535538 callback (
536539 context,
@@ -975,8 +978,7 @@ pub extern "C" fn operator_presign_write_async(
975978 callback : Option < PresignCallback > ,
976979 context : i64 ,
977980) -> OpendalResult {
978- match operator_presign_write_async_inner ( op, executor, path, expire_nanos, callback, context)
979- {
981+ match operator_presign_write_async_inner ( op, executor, path, expire_nanos, callback, context) {
980982 Ok ( ( ) ) => OpendalResult :: ok ( ) ,
981983 Err ( error) => OpendalResult :: from_error ( error) ,
982984 }
@@ -1090,8 +1092,7 @@ pub extern "C" fn operator_presign_delete_async(
10901092 callback : Option < PresignCallback > ,
10911093 context : i64 ,
10921094) -> OpendalResult {
1093- match operator_presign_delete_async_inner ( op, executor, path, expire_nanos, callback, context)
1094- {
1095+ match operator_presign_delete_async_inner ( op, executor, path, expire_nanos, callback, context) {
10951096 Ok ( ( ) ) => OpendalResult :: ok ( ) ,
10961097 Err ( error) => OpendalResult :: from_error ( error) ,
10971098 }
@@ -1168,8 +1169,8 @@ fn operator_input_stream_create_inner(
11681169
11691170 let _guard = executor. enter ( ) ;
11701171
1171- let blocking_op = opendal :: blocking :: Operator :: new ( op . clone ( ) )
1172- . map_err ( OpenDALError :: from_opendal_error) ?;
1172+ let blocking_op =
1173+ opendal :: blocking :: Operator :: new ( op . clone ( ) ) . map_err ( OpenDALError :: from_opendal_error) ?;
11731174 let reader = blocking_op
11741175 . reader_options ( & path, opendal:: options:: ReaderOptions :: default ( ) )
11751176 . map_err ( OpenDALError :: from_opendal_error) ?;
@@ -1200,7 +1201,9 @@ fn operator_input_stream_read_next_inner(
12001201 stream : * mut opendal:: blocking:: StdBytesIterator ,
12011202) -> Result < ByteBuffer , OpenDALError > {
12021203 if stream. is_null ( ) {
1203- return Err ( crate :: utils:: config_invalid_error ( "input stream pointer is null" ) ) ;
1204+ return Err ( crate :: utils:: config_invalid_error (
1205+ "input stream pointer is null" ,
1206+ ) ) ;
12041207 }
12051208
12061209 let stream = unsafe { & mut * stream } ;
@@ -1209,9 +1212,10 @@ fn operator_input_stream_read_next_inner(
12091212 . next ( )
12101213 . transpose ( )
12111214 . map_err ( |err| {
1212- OpenDALError :: from_opendal_error (
1213- opendal:: Error :: new ( opendal:: ErrorKind :: Unexpected , err. to_string ( ) ) ,
1214- )
1215+ OpenDALError :: from_opendal_error ( opendal:: Error :: new (
1216+ opendal:: ErrorKind :: Unexpected ,
1217+ err. to_string ( ) ,
1218+ ) )
12151219 } ) ?
12161220 . map ( |v| ByteBuffer :: from_vec ( v. to_vec ( ) ) )
12171221 . unwrap_or_else ( ByteBuffer :: empty) ;
@@ -1224,7 +1228,9 @@ fn operator_input_stream_read_next_inner(
12241228/// - `stream` must be null or a pointer returned by `operator_input_stream_create`.
12251229/// - Must be called at most once for the same pointer.
12261230#[ unsafe( no_mangle) ]
1227- pub unsafe extern "C" fn operator_input_stream_free ( stream : * mut opendal:: blocking:: StdBytesIterator ) {
1231+ pub unsafe extern "C" fn operator_input_stream_free (
1232+ stream : * mut opendal:: blocking:: StdBytesIterator ,
1233+ ) {
12281234 if stream. is_null ( ) {
12291235 return ;
12301236 }
@@ -1271,8 +1277,8 @@ fn operator_output_stream_create_inner(
12711277
12721278 let _guard = executor. enter ( ) ;
12731279
1274- let blocking_op = opendal :: blocking :: Operator :: new ( op . clone ( ) )
1275- . map_err ( OpenDALError :: from_opendal_error) ?;
1280+ let blocking_op =
1281+ opendal :: blocking :: Operator :: new ( op . clone ( ) ) . map_err ( OpenDALError :: from_opendal_error) ?;
12761282 let stream = blocking_op
12771283 . writer_options ( & path, options)
12781284 . map_err ( OpenDALError :: from_opendal_error) ?;
@@ -1327,14 +1333,18 @@ fn operator_output_stream_write_inner(
13271333///
13281334/// - `stream` must be a valid pointer returned by `operator_output_stream_create`.
13291335#[ unsafe( no_mangle) ]
1330- pub extern "C" fn operator_output_stream_flush ( stream : * mut opendal:: blocking:: Writer ) -> OpendalResult {
1336+ pub extern "C" fn operator_output_stream_flush (
1337+ stream : * mut opendal:: blocking:: Writer ,
1338+ ) -> OpendalResult {
13311339 match operator_output_stream_flush_inner ( stream) {
13321340 Ok ( ( ) ) => OpendalResult :: ok ( ) ,
13331341 Err ( error) => OpendalResult :: from_error ( error) ,
13341342 }
13351343}
13361344
1337- fn operator_output_stream_flush_inner ( stream : * mut opendal:: blocking:: Writer ) -> Result < ( ) , OpenDALError > {
1345+ fn operator_output_stream_flush_inner (
1346+ stream : * mut opendal:: blocking:: Writer ,
1347+ ) -> Result < ( ) , OpenDALError > {
13381348 if stream. is_null ( ) {
13391349 return Err ( crate :: utils:: config_invalid_error (
13401350 "output stream pointer is null" ,
@@ -1349,14 +1359,18 @@ fn operator_output_stream_flush_inner(stream: *mut opendal::blocking::Writer) ->
13491359///
13501360/// - `stream` must be a valid pointer returned by `operator_output_stream_create`.
13511361#[ unsafe( no_mangle) ]
1352- pub extern "C" fn operator_output_stream_close ( stream : * mut opendal:: blocking:: Writer ) -> OpendalResult {
1362+ pub extern "C" fn operator_output_stream_close (
1363+ stream : * mut opendal:: blocking:: Writer ,
1364+ ) -> OpendalResult {
13531365 match operator_output_stream_close_inner ( stream) {
13541366 Ok ( ( ) ) => OpendalResult :: ok ( ) ,
13551367 Err ( error) => OpendalResult :: from_error ( error) ,
13561368 }
13571369}
13581370
1359- fn operator_output_stream_close_inner ( stream : * mut opendal:: blocking:: Writer ) -> Result < ( ) , OpenDALError > {
1371+ fn operator_output_stream_close_inner (
1372+ stream : * mut opendal:: blocking:: Writer ,
1373+ ) -> Result < ( ) , OpenDALError > {
13601374 if stream. is_null ( ) {
13611375 return Err ( crate :: utils:: config_invalid_error (
13621376 "output stream pointer is null" ,
0 commit comments