inmem: Fix PipeSender to implement ReceiverFrom

Signed-off-by: Solomon Hykes <solomon@docker.com>
This commit is contained in:
Solomon Hykes 2014-05-13 22:43:56 -07:00
parent 1eb832dcbc
commit 91133d63be
1 changed files with 2 additions and 2 deletions

View File

@ -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
}