Remove Result from WebhookConsumer::new

hook-consumer/src/consumer.rs

@@ -32,7 +32,7 @@ impl<'p> WebhookConsumer<'p> {
         poll_interval: time::Duration,
         request_timeout: time::Duration,
         max_concurrent_jobs: usize,
-    ) -> Result<Self, WebhookConsumerError> {
+    ) -> Self {
         let mut headers = header::HeaderMap::new();
         headers.insert(
             header::CONTENT_TYPE,
@@ -45,13 +45,13 @@ impl<'p> WebhookConsumer<'p> {
             .build()
             .expect("failed to construct reqwest client for webhook consumer");
 
-        Ok(Self {
+        Self {
             name: name.to_owned(),
             queue,
             poll_interval,
             client,
             max_concurrent_jobs,
-        })
+        }
     }
 
     /// Wait until a job becomes available in our queue.
@@ -333,8 +333,8 @@ mod tests {
             time::Duration::from_millis(100),
             time::Duration::from_millis(5000),
             10,
-        )
-        .expect("consumer failed to initialize");
+        );
+
         let consumed_job = consumer
             .wait_for_job()
             .await

hook-consumer/src/main.rs

@@ -29,7 +29,7 @@ async fn main() -> Result<(), WebhookConsumerError> {
         config.poll_interval.0,
         config.request_timeout.0,
         config.max_concurrent_jobs,
-    )?;
+    );
 
     let _ = consumer.run().await;