MCPcopy Create free account
hub / github.com/apache/storm / readCommand

Function readCommand

storm-multilang/python/src/main/resources/resources/storm.py:69–77  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

67
68
69def readCommand():
70 if pending_commands:
71 return pending_commands.popleft()
72 else:
73 msg = readMsg()
74 while type(msg) is list:
75 pending_taskids.append(msg)
76 msg = readMsg()
77 return msg
78
79
80def readTuple():

Callers 2

readTupleFunction · 0.85
runMethod · 0.85

Calls 2

readMsgFunction · 0.85
appendMethod · 0.80

Tested by

no test coverage detected