From 91133d63be21cbcb636cacb8d7edd43883a66b5e Mon Sep 17 00:00:00 2001 From: Solomon Hykes Date: Tue, 13 May 2014 22:43:56 -0700 Subject: [PATCH] inmem: Fix PipeSender to implement ReceiverFrom Signed-off-by: Solomon Hykes --- inmem/inmem.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/inmem/inmem.go b/inmem/inmem.go index e5369a0660..451656123b 100644 --- a/inmem/inmem.go +++ b/inmem/inmem.go @@ -194,10 +194,10 @@ func (w *PipeSender) Send(msg *Message, mode int) (Receiver, Sender, error) { return w.p.send(msg, mode) } -func (w *PipeSender) ReceiveFrom(src Receiver, mode int) (int, error) { +func (w *PipeSender) ReceiveFrom(src Receiver) (int, error) { var n int for { - msg, msgr, msgw, err := src.Receive(mode) + msg, msgr, msgw, err := src.Receive(R|W) if err == io.EOF { break }