FutureProxy.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	/*
	* Copyright 2011 Facebook, Inc.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	abstract class FutureProxy extends Future {

	private $proxied;

	public function __construct(Future $proxied) {
	$this->proxied = $proxied;
	}

	public function isReady() {
	return $this->proxied->isReady();
	}

	public function resolve($timeout = null) {
	$this->proxied->resolve($timeout);
	return $this->getResult();
	}

	public function setException(Exception $ex) {
	$this->proxied->setException($ex);
	return $this;
	}

	public function getException() {
	return $this->proxied->getException();
	}

	public function getReadSockets() {
	return $this->proxied->getReadSockets();
	}

	public function getWriteSockets() {
	return $this->proxied->getWriteSockets();
	}

	protected function getResult() {
	if ($this->result === null) {
	$result = $this->proxied->resolve();
	$result = $this->didReceiveResult($result);
	$this->result = $result;
	}
	return $this->result;
	}

	public function start() {
	$this->proxied->start();
	return $this;
	}

	abstract protected function didReceiveResult($result);

	}