message: Fix formatting after merge
diff: @@ -559,8 +559,7 @@ where
  {
  let demands_in_flight = Arc::new(Semaphore::new(context.max_in_flight_demands));
  - let read_messages =
  - async move {
  + let read_messages = async move {
  while let Some(msg_result) = stream.next().await {
  match msg_result {
  Ok(msg) => {
  @@ -629,9 +628,11 @@ where
  // We've received a non-demand message. Ensure we have the proper amount
  // of resources, then push it to the reactor.
  limiter
  - .request_allowance(msg.payload_incoming_resource_estimate(
  + .request_allowance(
  + msg.payload_incoming_resource_estimate(
  &context.payload_weights,
  - ))
  + ),
  + )
  .await;
  let queue_kind = if msg.is_low_priority() {
  