add async stream consumer method to EventConsumer

[jeremymv2]

builder/components/builder-events/src/connection.rs

Lines 113 to 125 in bcb05a9

	/// Trait abstraction representing the configured Event Consumer. The Consumer is
	/// responsible for reading messages off of the message bus.
	pub trait EventConsumer {
	/// Subscribe to list of queues or topics
	fn subscribe(&self, queues: &[&str]) -> Result<(), Error>;
	/// Poll the topic(s) for new messages. When a message exists, its payload will be returned.
	/// This is a synchronous call.
	fn poll(&self) -> Option<Result<String, Error>>;
	// TODO (JM): Add an async stream consumer method, perhaps `consume_stream` or similar.
	// An example of a Kafka implementation of this is implemented via `StreamConsumer` [1].
	// [1] https://github.com/fede1024/rust-rdkafka/blob/master/src/consumer/stream_consumer.rs
	}

[stale]

This issue has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. We value your input and contribution. Please leave a comment if this issue still affects you.

[stale]

This issue has been automatically closed after being stale for 400 days. We still value your input and contribution. Please re-open the issue if desired and leave a comment with details.