Google Cloud Pub/Sub adapter for SSE Gateway
use sse_gateway::Gateway; use sse_gateway_gcp::GcpPubSubSource; Gateway::builder() .source(GcpPubSubSource::new("my-project", "my-subscription")) .storage(sse_gateway::MemoryStorage::default()) .build()? .run() .await