Wire up save_queue as a part of new_document rather than open

pull/2267/head
Blaž Hrastnik 2 years ago committed by Skyler Hawthorne
parent 55b50d9e83
commit 1b6f7319cd

@ -1062,6 +1062,13 @@ impl Editor {
DocumentId(unsafe { NonZeroUsize::new_unchecked(self.next_document_id.0.get() + 1) }); DocumentId(unsafe { NonZeroUsize::new_unchecked(self.next_document_id.0.get() + 1) });
doc.id = id; doc.id = id;
self.documents.insert(id, doc); self.documents.insert(id, doc);
let (save_sender, save_receiver) = tokio::sync::mpsc::unbounded_channel();
self.saves.insert(id, save_sender);
let stream = UnboundedReceiverStream::new(save_receiver).flatten();
self.save_queue.push(stream);
id id
} }
@ -1095,12 +1102,6 @@ impl Editor {
self.new_document(doc) self.new_document(doc)
}; };
let (save_sender, save_receiver) = tokio::sync::mpsc::unbounded_channel();
self.saves.insert(id, save_sender);
let stream = UnboundedReceiverStream::new(save_receiver).flatten();
self.save_queue.push(stream);
self.switch(id, action); self.switch(id, action);
Ok(id) Ok(id)
} }

Loading…
Cancel
Save