Fix #620
This commit is contained in:
parent
fc74d22724
commit
ddfe7797e5
1 changed files with 2 additions and 1 deletions
|
|
@ -5,6 +5,7 @@
|
|||
import json
|
||||
import re
|
||||
import sys
|
||||
import types
|
||||
from functools import partial
|
||||
|
||||
from .cli import emph, parse_args
|
||||
|
|
@ -83,7 +84,7 @@ def recv(self, more_needed, timeout):
|
|||
|
||||
def do_io(to, send, no_response):
|
||||
payload = send.get('payload')
|
||||
if payload is None or isinstance(payload, (str, bytes)):
|
||||
if not isinstance(payload, types.GeneratorType):
|
||||
send_data = encode_send(send)
|
||||
else:
|
||||
def send_generator():
|
||||
|
|
|
|||
Loading…
Reference in a new issue