Creating a Phoenix channel source
Hi! I need to process an audio stream (webm/opus) coming in through a channel (websocket) in phoenix and I'd like to use membrane to do it.
Is the way to do it to write my own membrane source that is essentially a "beam message source" - ie. reads messages sent to it from another process and then passes that along to the next stage in the pipeline? And then have the channel process send the message to the "beam message source" element
And then similarly if I want to send messages back to the channel at the end of the pipeline, would I be making a "beam message sink"
I'm pretty sure I can make that work but not sure if there's a better way in membrane
Is the way to do it to write my own membrane source that is essentially a "beam message source" - ie. reads messages sent to it from another process and then passes that along to the next stage in the pipeline? And then have the channel process send the message to the "beam message source" element
And then similarly if I want to send messages back to the channel at the end of the pipeline, would I be making a "beam message sink"
I'm pretty sure I can make that work but not sure if there's a better way in membrane
