Skip to content

Commit 18ae49e

Browse files
committed
fix rma example
1 parent d270dc8 commit 18ae49e

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

examples/rma.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,16 +18,16 @@ async fn client(server_addr: String) -> Result<()> {
1818
println!("client: connect to {:?}", server_addr);
1919
let context = Context::new().unwrap();
2020
let worker = context.create_worker().unwrap();
21-
let endpoint = worker
22-
.connect_socket(server_addr.parse().unwrap())
23-
.await
24-
.unwrap();
25-
endpoint.print_to_stderr();
2621
#[cfg(not(feature = "event"))]
2722
tokio::task::spawn_local(worker.clone().polling());
2823
#[cfg(feature = "event")]
2924
tokio::task::spawn_local(worker.clone().event_poll());
3025

26+
let endpoint = worker
27+
.connect_socket(server_addr.parse().unwrap())
28+
.await
29+
.unwrap();
30+
endpoint.print_to_stderr();
3131
// register memory region
3232
let mut buf: Vec<u8> = (0..0x1000).map(|x| x as u8).collect();
3333
let mem = MemoryHandle::register(&context, &mut buf);

0 commit comments

Comments
 (0)