How to close a WebSocket after calling .split() ?

[TristanCacqueray]

Describe the Bug

I can't figure how to call ws.close() after splitting the stream since that consumes the WebSocket.
Is it possible to make such code terminate the connection from an external event (here when associated dom element is removed)?

    let mut ws = WebSocket::open("ws://localhost:3030/wsapi/report/1").unwrap();

    let (mut write, mut read) = ws.split();

    let close_handler = move |_| {
        log!("Closing the ws");
        ws.close(None, None);
    };

    let read_handler = async move {
        while let Some(msg) = read.next().await {
            log!(&format!("Got {:?}", msg));
        }
    };

    html!("div", {.future(read_handler).after_removed(close_handler)})

This fails with

error[E0382]: use of moved value: `ws`
    --> crates/web/src/main.rs:261:25
     |
257  |     let mut ws = WebSocket::open("ws://localhost:3030/wsapi/report/1").unwrap();
     |         ------ move occurs because `ws` has type `gloo_net::websocket::futures::WebSocket`, which does not implement the `Copy` trait
258  |
259  |     let (mut write, mut read) = ws.split();
     |                                    ------- `ws` moved due to this method call
260  |
261  |     let close_handler = move |_| {
     |                         ^^^^^^^^ value used here after move
262  |         log!("Closing the ws");
263  |         ws.close(None, None);
     |         -- use occurs due to use in closure

Thanks!

[ranile]

Does dropping the split parts should close the WS connection?

WebSocket has a Drop implementation for this:

gloo/crates/net/src/websocket/futures.rs

Lines 328 to 351 in 1b6a4fa

	impl PinnedDrop for WebSocket {
	fn drop(self: Pin<&mut Self>) {
	self.ws.close().unwrap();
	for (ty, cb) in [
	("open", self.closures.0.as_ref()),
	("message", self.closures.1.as_ref()),
	("error", self.closures.2.as_ref()),
	] {
	let _ = self
	.ws
	.remove_event_listener_with_callback(ty, cb.unchecked_ref());
	}
	if let Ok(close_event) = web_sys::CloseEvent::new_with_event_init_dict(
	"close",
	web_sys::CloseEventInit::new()
	.code(1000)
	.reason("client dropped"),
	) {
	let _ = self.ws.dispatch_event(&close_event);
	}
	}
	}