Some things could not properly fixed to keep compatibility with Akka 2.5. Since we don't care anymore about 2.5, we can clean things up. * stream cancellation handling (getting causes in `onDownstreamFinish`)