--- a/rust/src/fridge.rs	Tue Feb 06 22:16:44 2018 +0800
+++ b/rust/src/fridge.rs	Fri Apr 19 13:57:40 2019 +0800
@@ -10,6 +10,7 @@
 use std::time::{Duration,Instant};
 
 use futures::{Future,future,Sink,Stream};
+use futures_sink::{Sink};
 use tokio_core::reactor::{Timeout,Handle};
 use futures::sync::{mpsc};
 
@@ -52,9 +53,9 @@
     type SinkError = TemplogError;
 
     fn start_send(&mut self, msg: Message)
-            -> futures::StartSend<Self::SinkItem, Self::SinkError> {
+            -> Result<(), Self::SinkError> {
         self.process_msg(msg);
-        Ok(futures::AsyncSink::Ready)
+        Ok()
     }
 
     fn poll_complete(&mut self) -> futures::Poll<(), Self::SinkError> {