Called by :py:class:`PipeEngine` when there is a new message for the low entry. :param msg: The message data :returns: None :rtype: None
(self, msg)
| 406 | :type name: str |
| 407 | """ |
| 408 | def push(self, msg): |
| 409 | # type: (Any) -> None |
| 410 | """ |
| 411 | Called by :py:class:`PipeEngine` when there is a new message for the |
| 412 | low entry. |
| 413 | |
| 414 | :param msg: The message data |
| 415 | :returns: None |
| 416 | :rtype: None |
| 417 | """ |
| 418 | pass |
| 419 | |
| 420 | def high_push(self, msg): |
| 421 | # type: (Any) -> None |