diff options
author | 2025-01-02 17:48:12 +0000 | |
---|---|---|
committer | 2025-01-02 17:48:12 +0000 | |
commit | 0e5f09b2bd05690f3d28f7076629031fcc2cc6e6 (patch) | |
tree | 29409764a94d570c8d9e929f1751a678355cb6ee /jabber/src/jabber_stream/bound_stream.rs | |
parent | 89351e956368ad3112127570ef03dd2547730ce5 (diff) | |
download | luz-0e5f09b2bd05690f3d28f7076629031fcc2cc6e6.tar.gz luz-0e5f09b2bd05690f3d28f7076629031fcc2cc6e6.tar.bz2 luz-0e5f09b2bd05690f3d28f7076629031fcc2cc6e6.zip |
WIP: client
Diffstat (limited to 'jabber/src/jabber_stream/bound_stream.rs')
-rw-r--r-- | jabber/src/jabber_stream/bound_stream.rs | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/jabber/src/jabber_stream/bound_stream.rs b/jabber/src/jabber_stream/bound_stream.rs index c0d67b0..627158a 100644 --- a/jabber/src/jabber_stream/bound_stream.rs +++ b/jabber/src/jabber_stream/bound_stream.rs @@ -63,6 +63,7 @@ where if let Some(_write_handle) = this.write_handle { panic!("start_send called without poll_ready") } else { + // TODO: switch to buffer of one rather than thread spawning and joining *this.write_handle = Some(tokio::spawn(write(this.writer.clone(), item))); Ok(()) } |