what needs to happen is CtpStreamSource gets a ref of StreamInboundHandler
and methods to say "give me more".
the underlying ByteToMessageDecoder needs to have a "resume" feature
that keeps reading from the current buffer and processing the
rather than StreamInboundHandler being in the pipeline, probably it should just be a class
that is handed to CtpStreamDecoder as one option for message handling.
so this class may become obsolete as this code may begin to merge with CtpStreamSource.
switching to Shared then is merely replacing CtpStreamSource with the switching handler
and then in turn replacing with the shared handler.