message: Fix failing test with nats-server 2.8.0
diff: @@ -250,7 +250,7 @@ fn jetstream_publish() {
  fn jetstream_subscribe() {
  let s = util::run_server("tests/configs/jetstream.conf");
  let nc = nats::connect(&s.client_url()).unwrap();
  - let js = nats::jetstream::new(nc);
  + let js = nats::jetstream::new(nc.clone());
  js.add_stream(&StreamConfig {
  name: "TEST".to_string(),
  @@ -280,6 +280,7 @@ fn jetstream_subscribe() {
  assert_eq!(msg.data, payload);
  }
  + nc.flush().unwrap();
  // Check the state of consumer matches up with our expectations
  let info = sub.consumer_info().unwrap();
  assert_eq!(info.config.ack_policy, AckPolicy::Explicit);
  @@ -700,7 +701,7 @@ fn jetstream_pull_subscribe_fetch_with_handler() {
  .error_callback(|err| println!("error!: {}", err))
  .connect(&s.client_url())
  .unwrap();
  - let js = nats::jetstream::new(nc);
  + let js = nats::jetstream::new(nc.clone());
  js.add_stream(&StreamConfig {
  name: "TEST".to_string(),
  @@ -738,6 +739,7 @@ fn jetstream_pull_subscribe_fetch_with_handler() {
  })
  .unwrap();
  + nc.flush().unwrap();
  let info = js.consumer_info("TEST", "CONSUMER").unwrap();
  assert_eq!(info.num_ack_pending, 0);
  assert_eq!(info.num_pending, 5);
  