Постановка задачи не понятна вообще. Что должно быть, зачем, почему, куда все это отправляется, что должно получиться. Ты думаешь, что глядя на твою схему, можно определить почему не работает, не зная, что должно быть в результате. К тому же, Memory не должно заносить данные в поток, оно должно их хранить, а может они читаются, когда еще не актуальны