From 7601d49283aac0c11fd173a187f47c1ab4732b59 Mon Sep 17 00:00:00 2001 From: Solomon Hykes Date: Wed, 18 Jun 2014 23:50:07 -0700 Subject: [PATCH] Implement NopSender (removed by switch to libchan) Signed-off-by: Solomon Hykes --- beam/nop.go | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 beam/nop.go diff --git a/beam/nop.go b/beam/nop.go new file mode 100644 index 0000000000..9d3cabb392 --- /dev/null +++ b/beam/nop.go @@ -0,0 +1,30 @@ +package beam + +import ( + "github.com/docker/libchan" + "io" +) + +type NopSender struct{} + +func (s NopSender) Send(msg *Message) (Receiver, error) { + return NopReceiver{}, nil +} + +func (s NopSender) Close() error { + return nil +} + +func (s NopSender) Unwrap() libchan.Sender { + return libchan.NopSender{} +} + +type NopReceiver struct{} + +func (r NopReceiver) Receive(mode int) (*Message, error) { + return nil, io.EOF +} + +func (r NopReceiver) Unwrap() libchan.Receiver { + return libchan.NopReceiver{} +}