Plumbing StreamSockets to std::streambuf

[philipp]

I have an app (much like an ALG, or application-level gateway) that reads data from a Net::StreamSocket, mangles it, and writes it to another Net::StreamSocket.

It needs to do so in real-time and without blocking. So I wanted to use a std::streambuf to move the data-through.

Has anyone done anything similar already?

I wanted to use a Net::SocketReactor to deliver read notifications of when I can read data from the source socket and append it to the streambuf, and use write notifications when I can write some or all of the buffered data to the destination socket.

Thanks.

[philipp]

Actually, I was thinking about this some more, and what's really needed is a "soft" pipe abstraction, that can be used to implement a buffered pipe used by two threads within the same process, for example. The 'producer' would write data into the pipe, and the 'consumer' would read it from the same.

There could be primitives to query the pipe how much unread data it holds, as well as how much space remains before blocking and/or having a 'short write' to the pipe.

Would this be derived from a BasicBufferedStreamBuf?