wire: fix write_message, pbuf dumps is sync now

This commit is contained in:
Jan Pochyla 2016-10-06 14:52:07 +02:00
parent 4b0da8677a
commit c019741c33
1 changed files with 1 additions and 1 deletions

View File

@ -91,7 +91,7 @@ async def read_message(session_id, *exp_types):
async def write_message(session_id, pbuf_message): async def write_message(session_id, pbuf_message):
log.info(__name__, 'writing message %s', pbuf_message) log.info(__name__, 'writing message %s', pbuf_message)
msg_data = await pbuf_message.dumps() msg_data = pbuf_message.dumps()
msg_type = pbuf_message.message_type.wire_type msg_type = pbuf_message.message_type.wire_type
if session_id == SESSION_V1: if session_id == SESSION_V1: