decomposed StreamProxy, simplified messaging