beam: upgrade the API with Sender/Receiver interfaces and utilities: Copy/SendPipe/SendPair