Collects the value emitted by the upstream. This method is not thread-safe and should not be invoked concurrently.