Searched refs:stream_tx (Results 1 – 1 of 1) sorted by relevance
80 let stream_tx = Arc::clone(&stream); in main() localVariable86 stream_tx.write(&Bytes::from(ping_msg)).await?; in main()