(tup, stream=None, anchors=[], directTask=None)
| 117 | |
| 118 | |
| 119 | def emitBolt(tup, stream=None, anchors=[], directTask=None): |
| 120 | global ANCHOR_TUPLE |
| 121 | if ANCHOR_TUPLE is not None: |
| 122 | anchors = [ANCHOR_TUPLE] |
| 123 | m = {"command": "emit"} |
| 124 | if stream is not None: |
| 125 | m["stream"] = stream |
| 126 | m["anchors"] = [a.id for a in anchors] |
| 127 | if directTask is not None: |
| 128 | m["task"] = directTask |
| 129 | m["tuple"] = tup |
| 130 | sendMsgToParent(m) |
| 131 | |
| 132 | |
| 133 | def emitSpout(tup, stream=None, id=None, directTask=None): |
no test coverage detected