2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-26 03:19:48 +00:00

Fix another python3 syntax problem

async can't even be a member of
a class, evidently.
This commit is contained in:
Jarrod Johnson 2020-04-10 12:11:45 -04:00
parent 989ae614c9
commit 2575e32209

View File

@ -65,11 +65,11 @@ class AsyncTermRelation(object):
# This allows the async handler to know the context of
# outgoing data to provide to calling code
def __init__(self, termid, asynchdl):
self.async = asynchdl
self.asynchdl = asynchdl
self.termid = termid
def got_data(self, data):
self.async.add(self.termid, data)
self.asynchdl.add(self.termid, data)
class AsyncSession(object):