Skip to content

Commit 8258f06

Browse files
author
Ramon Navarro Bosch
committed
init can't be a generator
1 parent 54e09e7 commit 8258f06

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

fluent/event.py

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,13 @@ def __init__(self, label, data, **kwargs):
1414

1515

1616
class AsyncEvent(object):
17-
async def __init__(self, label, data, **kwargs):
17+
def __init__(self, label, data, **kwargs):
1818
assert isinstance(data, dict), 'data must be a dict'
19-
sender_ = kwargs.get('sender', sender.get_global_sender())
20-
timestamp = kwargs.get('time', int(time.time()))
21-
await sender_.async_emit_with_time(label, timestamp, data)
19+
self.label = label
20+
self.data = data
21+
self.sender_ = kwargs.get('sender', sender.get_global_sender())
22+
self.timestamp = kwargs.get('time', int(time.time()))
23+
24+
async def __call__(self):
25+
await self.sender_.async_emit_with_time(
26+
self.label, self.timestamp, self.data)

0 commit comments

Comments
 (0)