feat: make ConcurrentLimitLayer accept Semaphore

bindings/java/src/layer.rs

@@ -59,6 +59,6 @@ pub extern "system" fn Java_org_apache_opendal_layer_ConcurrentLimitLayer_doLaye
     permits: jlong,
 ) -> jlong {
     let op = unsafe { &*op };
-    let concurrent_limit = ConcurrentLimitLayer::new(permits as usize);
+    let concurrent_limit = ConcurrentLimitLayer::with_permits(permits as usize);
     Box::into_raw(Box::new(op.clone().layer(concurrent_limit))) as jlong
 }

bindings/nodejs/src/layer.rs

@@ -224,7 +224,7 @@ impl ConcurrentLimitLayer {
     #[napi]
     pub fn build(&self) -> External<Layer> {
         let permits = self.permits;
-        let mut l = opendal::layers::ConcurrentLimitLayer::new(permits as usize);
+        let mut l = opendal::layers::ConcurrentLimitLayer::with_permits(permits as usize);
 
         if let Some(http_permits) = self.http_permits {
             l = l.with_http_concurrent_limit(http_permits as usize);

bindings/python/src/layers.rs

@@ -149,7 +149,7 @@ impl ConcurrentLimitLayer {
     #[new]
     #[pyo3(signature = (limit))]
     fn new(limit: usize) -> PyResult<PyClassInitializer<Self>> {
-        let concurrent_limit = Self(ocore::layers::ConcurrentLimitLayer::new(limit));
+        let concurrent_limit = Self(ocore::layers::ConcurrentLimitLayer::with_permits(limit));
         let class = PyClassInitializer::from(Layer(Box::new(concurrent_limit.clone())))
             .add_subclass(concurrent_limit);
 

bindings/ruby/src/middlewares.rs

@@ -87,7 +87,7 @@ struct ConcurrentLimitMiddleware(Arc<Mutex<ocore::layers::ConcurrentLimitLayer>>
 impl ConcurrentLimitMiddleware {
     fn new(permits: usize) -> Self {
         Self(Arc::new(Mutex::new(
-            ocore::layers::ConcurrentLimitLayer::new(permits),
+            ocore::layers::ConcurrentLimitLayer::with_permits(permits),
         )))
     }