old_contents: import json
  import threading
  import socket
  import SocketServer
  
  from orderbook import asks, bids
  
  
  class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
  
      def handle(self):
          try:
              while True:
                  data = self.request.recv(1024)
                  if data:
                      response = handle_data(data)
                  cur_thread = threading.current_thread()
                  response = "\n{}: {}".format(cur_thread.name, data)
                  self.request.sendall(response)
          except socket.error:
              # Surpress errno 13 Broken Pipe
              pass
  
  
  class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
      pass
  
  
  def create_server(host="localhost", port=0):
      server = ThreadedTCPServer((host, port), ThreadedTCPRequestHandler)
      server_thread = threading.Thread(target=server.serve_forever)
      server_thread.daemon = True
      server_thread.start()
      return server
  
  
  def handle_data(data):
      data = json.loads(data)
      if data['type'] == 'ask':
          handle_ask(data)
      elif data['type'] == 'bid':
          handle_bid(data)
      elif data['type'] == 'greeting':
          handle_greeting(data)
  
  
  def handle_ask(ask):
      asks.append(ask)
  
  
  def handle_bid(bid):
      bids.append(bid)
  
  
  def handle_greeting(greeting):
      pass
  
new_contents: import json
  import threading
  import socket
  import SocketServer
  
  from orderbook import asks, bids
  
  
  class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
  
      def handle(self):
          try:
              while True:
                  data = self.request.recv(1024)
                  response = ''
                  if data:
                      response += handle_data(data)
                      cur_thread = threading.current_thread()
                      response += "\n{}: {}".format(cur_thread.name, data)
                  self.request.sendall(response)
          except socket.error:
              # Surpress errno 13 Broken Pipe
              pass
  
  
  class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
      pass
  
  
  def create_server(host="localhost", port=0):
      server = ThreadedTCPServer((host, port), ThreadedTCPRequestHandler)
      server_thread = threading.Thread(target=server.serve_forever)
      server_thread.daemon = True
      server_thread.start()
      return server
  
  
  def handle_data(data):
      data = json.loads(data)
      if data['type'] == 'ask':
          handle_ask(data)
      elif data['type'] == 'bid':
          handle_bid(data)
      elif data['type'] == 'greeting':
          handle_greeting(data)
  
  
  def handle_ask(ask):
      asks.append(ask)
  
  
  def handle_bid(bid):
      bids.append(bid)
  
  
  def handle_greeting(greeting):
      pass
  
subject: Fix bugs occuring when no response is given.