[WIP] beam/inmem: switch to a Sender/Receiver/Pipe interface similar to io.Pipe