exc

exception unistream.exc.BufferIsEmptyError[source]

Raised when try to take item from an empty buffer.

exception unistream.exc.SendError[source]

Raised when producer failed to send records.

exception unistream.exc.ProcessError[source]

Raised when consumer failed to process record.

exception unistream.exc.StreamIsClosedError[source]

Raised when stream says that you cannot consume from it. This is not about stream is disconnected. The stream system is still healthy, but it confirms that you cannot consume from it due to recent node re-balance or other reasons.