Traceback (most recent call last):
  File "processor/worker.py", line 32, in process_request
    await nats.publish(request.reply, json.dumps(self._serialize(result)).encode())
  File "/Users/frederikfix/src/bugzoo/processor/processor/trio_nats/client.py", line 47, in publish
    await self.client_stream.send_all(pub_cmd)
  File "/Users/frederikfix/.local/share/virtualenvs/processor-8DvzDI5i/lib/python3.7/site-packages/trio/_highlevel_socket.py", line 105, in send_all
    with self._send_conflict_detector:
  File "/Users/frederikfix/.local/share/virtualenvs/processor-8DvzDI5i/lib/python3.7/site-packages/trio/_util.py", line 122, in __enter__
    raise trio.BusyResourceError(self._msg)
trio.BusyResourceError: another task is currently sending data on this SocketStream

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "processor/worker.py", line 57, in <module>
    run(args)
  File "processor/worker.py", line 50, in run
    trio.run(worker.run)
  File "/Users/frederikfix/.local/share/virtualenvs/processor-8DvzDI5i/lib/python3.7/site-packages/trio/_core/_run.py", line 1783, in run
    raise runner.main_task_outcome.error
  File "processor/worker.py", line 20, in run
    nursery.start_soon(self.listen_for_requests, service, nats, nursery, subscription)
  File "/Users/frederikfix/.local/share/virtualenvs/processor-8DvzDI5i/lib/python3.7/site-packages/trio/_core/_run.py", line 725, in __aexit__
    raise combined_error_from_nursery
  File "processor/worker.py", line 34, in process_request
    await nats.publish(request.reply, json.dumps(["error", f"{type(e)}: {e}"]).encode())
  File "/Users/frederikfix/src/bugzoo/processor/processor/trio_nats/client.py", line 47, in publish
    await self.client_stream.send_all(pub_cmd)
  File "/Users/frederikfix/.local/share/virtualenvs/processor-8DvzDI5i/lib/python3.7/site-packages/trio/_highlevel_socket.py", line 105, in send_all
    with self._send_conflict_detector:
  File "/Users/frederikfix/.local/share/virtualenvs/processor-8DvzDI5i/lib/python3.7/site-packages/trio/_util.py", line 122, in __enter__
    raise trio.BusyResourceError(self._msg)
trio.BusyResourceError: another task is currently sending data on this SocketStream