How to process payload from notify after collected notify?

[Barto-Paja]

Hello,
I'm trying to process the collected payload from a notification. When I receive notification from PostgreSQL database, I would like to insert new data into the db.
I took the code from example

rust-postgres/tokio-postgres/tests/test/main.rs

Lines 736 to 769 in 98f5a11

	#[tokio::test]
	async fn notifications() {
	let (client, mut connection) = connect_raw("user=postgres").await.unwrap();
	let (tx, rx) = mpsc::unbounded();
	let stream =
	stream::poll_fn(move |cx| connection.poll_message(cx)).map_err(|e| panic!("{}", e));
	let connection = stream.forward(tx).map(|r| r.unwrap());
	tokio::spawn(connection);
	client
	.batch_execute(
	"LISTEN test_notifications;
	NOTIFY test_notifications, 'hello';
	NOTIFY test_notifications, 'world';",
	)
	.await
	.unwrap();
	drop(client);
	let notifications = rx
	.filter_map(|m| match m {
	AsyncMessage::Notification(n) => future::ready(Some(n)),
	_ => future::ready(None),
	})
	.collect::<Vec<_>>()
	.await;
	assert_eq!(notifications.len(), 2);
	assert_eq!(notifications[0].channel(), "test_notifications");
	assert_eq!(notifications[0].payload(), "hello");
	assert_eq!(notifications[1].channel(), "test_notifications");
	assert_eq!(notifications[1].payload(), "world");
	}

something like this:

let notifications = rx
    .filter_map(|m| match m {
        AsyncMessage::Notification(n) => {
            println!("Notification {:?}", n);
            // insert_stuff(connection_parameters, n.payload()) <-- insert new data into db, but here asking for add await
            future::ready(Some(n))
        },
        _ => future::ready(None),
    })
    .collect::<Vec<_>>()
    .await;

Note: newbie in rust