diff --git a/inmem/buf.go b/inmem/buf.go new file mode 100644 index 0000000000..32243e0e2d --- /dev/null +++ b/inmem/buf.go @@ -0,0 +1,15 @@ +package inmem + +import () + +type Buffer []*Message + +func (buf *Buffer) Send(msg *Message, mode int) (Receiver, Sender, error) { + (*buf) = append(*buf, msg) + return NopReceiver{}, NopSender{}, nil +} + +func (buf *Buffer) Close() error { + (*buf) = nil + return nil +}