|
| m_id_ |
|
| client_ |
|
| handle_ |
|
| stream_ |
|
◆ __init__()
def confluo.rpc.stream.AlertStream.__init__ |
( |
|
self, |
|
|
|
m_id, |
|
|
|
client, |
|
|
|
handle |
|
) |
| |
Initializes a stream of alerts to the data passed in.
Args:
m_id: The identifier of the atomic multilog.
client: The rpc client.
handle: The iterator for the stream.
◆ __iter__()
def confluo.rpc.stream.AlertStream.__iter__ |
( |
|
self | ) |
|
Iterates through the alert stream.
Yields:
alert: The next alert in the stream.
◆ has_more()
def confluo.rpc.stream.AlertStream.has_more |
( |
|
self | ) |
|
Checks whether the stream has any more elements.
Returns:
True if there are any elements left in the stream, false otherwise.
The documentation for this class was generated from the following file:
- /Users/anuragk/Work/Projects/Confluo/confluo/pyclient/confluo/rpc/stream.py