Unverified Commit 0b0d9877 authored by Niklas Adolfsson's avatar Niklas Adolfsson
Browse files

revert benchmark change

parent c5d46eea
......@@ -142,10 +142,12 @@ pub async fn ws_server(handle: tokio::runtime::Handle) -> (String, jsonrpsee::ws
module
.register_subscription(SUB_METHOD_NAME, SUB_METHOD_NAME, UNSUB_METHOD_NAME, |_params, pending, _ctx| {
let mut sink = match pending.accept() {
Some(sink) => sink,
_ => return,
};
let x = "Hello";
let sink = pending.accept().unwrap();
let _ = sink.send(&x);
tokio::spawn(async move { sink.send(&x) });
})
.unwrap();
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment