# HG changeset patch # User Matt Johnston # Date 1555653460 -28800 # Node ID e1b5938de122e9902a61bd4ce6cf483350a529bd # Parent d5075136442fdf94723bae8f899c785735ed4edd futures sink? unsure what this was diff -r d5075136442f -r e1b5938de122 rust/src/fridge.rs --- 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 { + -> Result<(), Self::SinkError> { self.process_msg(msg); - Ok(futures::AsyncSink::Ready) + Ok() } fn poll_complete(&mut self) -> futures::Poll<(), Self::SinkError> {