Make user of EgressResponse.from manage the Observable lifecycle