Hi all! I am trying to program a pipeline that takes data in chunks from a shared-memory-based ring buffer, and processes each chunk. After quite a bit of thought, I decided that programming this asynchronously is the way to go, since I want to start processing data as soon as new chunk of it comes in, and then go back to waiting for the next chunk. Since I am new to this, I am just a bit unsure how to proceed. From what I can see, it would be good to program a custom Channel for this, which can send or receive data from the ring buffer. Could someone guide me on how to implement the send and receive methods in general? Some examples on how to code your own custom Channels would be helpful.