Merge pull request #27 from MaterializeInc/relax-clone-bound

relax clone trait bound on context

src/producer/base_producer.rs

@@ -494,7 +494,6 @@ where
 /// queued events, such as delivery notifications. The thread will be
 /// automatically stopped when the producer is dropped.
 #[must_use = "The threaded producer will stop immediately if unused"]
-#[derive(Clone)]
 pub struct ThreadedProducer<C>
 where
     C: ProducerContext + 'static,
@@ -623,6 +622,16 @@ where
     }
 }
 
+impl<C: ProducerContext + 'static> Clone for ThreadedProducer<C> {
+    fn clone(&self) -> Self {
+        Self {
+            producer: self.producer.clone(),
+            should_stop: Arc::clone(&self.should_stop),
+            handle: self.handle.clone(),
+        }
+    }
+}
+
 impl<C> Drop for ThreadedProducer<C>
 where
     C: ProducerContext + 'static,