yr.fnruntime.Producer.send

Contents

yr.fnruntime.Producer.send#

Producer.send(self, element: Element, int timeout_ms: int = None) → None#

The Producer sends data, which is first placed into a buffer. The buffer is then flushed either according to the configured automatic flush strategy (after a certain interval or when the buffer is full), or by manually invoking the flush operation to make the data accessible to the consumer.

Parameters:

  • element (Element) – The Element data to be sent.

  • timeout_ms (int, optional) – The timeout in milliseconds. Defaults to None.

Raises:

RuntimeError – If the send operation fails.

Contents