Currently, we hold a stream::Shared within the stream and one in Active. This is shared by being wrapped in Arc<Mutex>.

It would be slightly more ergonomic for both usage sites if the Arc<Mutex> would be inside stream::Shared.