Multithreaded block queue

2016-01-17 23:07:58 +01:00
parent 1e8dd6321f
commit a131c33bb2
12 changed files with 317 additions and 95 deletions
--- a/util/src/io/service.rs
+++ b/util/src/io/service.rs
@@ -155,7 +155,7 @@ pub struct IoChannel<Message> where Message: Send {
 }

 impl<Message> IoChannel<Message> where Message: Send {
-	pub fn send(&mut self, message: Message) -> Result<(), IoError> {
+	pub fn send(&self, message: Message) -> Result<(), IoError> {
 		try!(self.channel.send(IoMessage::UserMessage(message)));
 		Ok(())
 	}