fix(*): acquire permit for work after receive msg

Signed-off-by: Brooks Townsend <brooks@cosmonic.com>

Author: brooksmtownsend

Cargo.lock

@@ -1,7 +1,7 @@
 [package]
 name = "wadm"
 description = "wasmCloud Application Deployment Manager: A tool for running Wasm applications in wasmCloud"
-version = "0.5.0-alpha.1"
+version = "0.5.0-alpha.2"
 edition = "2021"
 authors = ["wasmCloud Team"]
 keywords = ["webassembly", "wasmcloud", "wadm"]
@@ -60,7 +60,7 @@ tracing-subscriber = { version = "0.3.7", features = [
 ], optional = true }
 uuid = "1"
 wasmbus-rpc = "0.14"
-wasmcloud-control-interface = "0.28"
+wasmcloud-control-interface = "0.28.1"
 semver = { version = "1.0.16", features = ["serde"] }
 
 [dev-dependencies]

Cargo.toml

@@ -267,12 +267,13 @@ where
     C: Stream<Item = Result<ScopedMessage<W::Message>, async_nats::Error>> + Unpin,
 {
     loop {
+        // Get next value from stream, returning error if the consumer stopped
+        let res = consumer.next().await.ok_or(WorkError::ConsumerStopped)?;
+
         // Grab a permit to do some work. This will only return errors if the pool is closed
         trace!("Getting work permit");
         let _permit = permits.acquire().await?;
         trace!("Received work permit, attempting to pull from consumer");
-        // Get next value from stream, returning error if the consumer stopped
-        let res = consumer.next().await.ok_or(WorkError::ConsumerStopped)?;
         let res = match res {
             Ok(msg) => {
                 trace!(message = ?msg, "Got message from consumer");