Confluo  0.1.0
Public Member Functions | Public Attributes | List of all members
confluo.rpc.stream.AlertStream Class Reference

Public Member Functions

def __init__ (self, m_id, client, handle)
 
def __iter__ (self)
 
def has_more (self)
 

Public Attributes

 m_id_
 
 client_
 
 handle_
 
 stream_
 

Detailed Description

A stream of alerts.

Constructor & Destructor Documentation

◆ __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.

Member Function Documentation

◆ __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: