def publish(self):
while not self.ws.closed:<EOL><INDENT>gevent.sleep(self.lag_tolerance_secs)<EOL>message = self.ws.receive()<EOL>if message is not None:<EOL><INDENT>channel_name, data = message.split("<STR_LIT::>", <NUM_LIT:1>)<EOL>redis_conn.publish(channel_name, data)<EOL><DEDENT><DEDENT>
Relay messages from client to redis.