in support/gym_remote/bridge.py [0:0]
def __init__(self, base):
self.base = base
self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
def close(message):
self.close()
if 'exception' in message:
import gym_remote.exceptions as gre
exception = gre.make(message['exception'], message['reason'])
else:
exception = self.Closed(message['reason'])
raise exception
def exception(message):
import gym_remote.exceptions as gre
raise gre.make(message['exception'], message['reason'])
self._channels = {}
self.connection = None
self._buffer = []
self._message_handlers = {
'update': self.update_vars,
'close': close,
'exception': exception
}