@@ -59,6 +59,7 @@ class ExampleServer(ServerEvents):

 	# helper methods

 	methods = set(['add', 'subtract'])

 	def _get_msg(self, response):

+		print('response', repr(response))

 		return ' '.join(str(x) for x in [response.id, response.result or response.error])

 	def subtract(self, a, b):

@@ -77,12 +77,20 @@ class ServerEvents(object):

 		'''Given the freshly decoded content of the request, return what content should be used'''

 		return content

-	def setResponseCode(self, result, request):

-		code = 200

+	def getresponsecode(self, result):

+		# returns 200 so that the python client can see something useful

+		return 200

+		# for example

+		#code = 200

 		#if not isinstance(result, list):

 		#	if result is not None and result.error is not None:

 		#		code = result.error.code or 500

-		request.setResponseCode(code)

+		#return code

+

+	def defer(self, method, *a, **kw):

+		# Defer to thread. Override this method if you are using a different ThreadPool,

+		# 	or if you want to return immediately.

+		return threads.deferToThread(method, *a, **kw)

@@ -107,6 +115,7 @@ class JSON_RPC(Resource):

 	def render(self, request):

+		result = ''

 		request.content.seek(0, 0)

 		try:

 			try:

@@ -135,6 +144,8 @@ class JSON_RPC(Resource):

 		return server.NOT_DONE_YET

+

+

 	def _action(self, request, contents, **kw):

 		result = []

@@ -153,7 +164,7 @@ class JSON_RPC(Resource):

 			res = None

 			add = copy.deepcopy(rpcrequest.extra)

 			add.update(kw)

-			deferreds.append(threads.deferToThread(callmethod, request, rpcrequest, add))

+			deferreds.append(self.eventhandler.defer(callmethod, request, rpcrequest, add))

 		deferreds = defer.DeferredList(deferreds, consumeErrors=True)

 		@deferreds.addCallback

@@ -182,9 +193,10 @@ class JSON_RPC(Resource):

 	def _cbRender(self, result, request):

-		@threads.deferToThread

+		@self.eventhandler.defer

 		def _inner(*args, **_):

-			self.eventhandler.setResponseCode(result, request)

+			code = self.eventhandler.getresponsecode(result)

+			request.setResponseCode(code)

 			self.eventhandler.log(result, request, error=False)

 			if result is not None:

 				request.setHeader("content-type", 'application/json')

@@ -195,7 +207,7 @@ class JSON_RPC(Resource):

 		return _inner

 	def _ebRender(self, result, request, id, finish=True):

-		@threads.deferToThread

+		@self.eventhandler.defer

 		def _inner(*args, **_):

 			err = None

 			if not isinstance(result, BaseException):

@@ -204,9 +216,10 @@ class JSON_RPC(Resource):

 					err = e

 					self.eventhandler.log(err, request, error=True)

 			else: err = result

-

 			err = self.render_error(err, id)

-			self.eventhandler.setResponseCode(err, request)

+

+			code = self.eventhandler.getresponsecode(result)

+			request.setResponseCode(code)

 			request.setHeader("content-type", 'application/json')

 			result_ = jsonrpc.jsonutil.encode(err).encode('utf-8')

@@ -215,7 +228,6 @@ class JSON_RPC(Resource):

 			if finish: request.finish()

 		return _inner

-

 	def render_error(self, e, id):

 		if isinstance(e, jsonrpc.common.RPCError):

 			err = jsonrpc.common.Response(id=id, error=e)