fixing offset in SuperstreamConsumer

DanielePalaia · DanielePalaia · commit e590d11c416d · 2024-10-21T10:16:43.000+02:00
diff --git a/src/superstream_consumer.rs b/src/superstream_consumer.rs
@@ -11,7 +11,6 @@ pub struct SuperStreamConsumer {
 }
 
 struct SuperStreamConsumerInternal {
-    offset_specification: OffsetSpecification,
     consumers: Vec<Consumer>,
 }
 
@@ -51,10 +50,7 @@ impl SuperStreamConsumerBuilder {
             consumers.push(consumer);
         }
 
-        let super_stream_consumer_internal = Arc::new(SuperStreamConsumerInternal {
-            offset_specification: self.offset_specification.clone(),
-            consumers,
-        });
+        let super_stream_consumer_internal = Arc::new(SuperStreamConsumerInternal { consumers });
 
         Ok(SuperStreamConsumer {
             internal: super_stream_consumer_internal,

Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,6 @@ pub struct SuperStreamConsumer {`
`11`	`11`	`}`
`12`	`12`
`13`	`13`	`struct SuperStreamConsumerInternal {`
`14`		`- offset_specification: OffsetSpecification,`
`15`	`14`	`consumers: Vec<Consumer>,`
`16`	`15`	`}`
`17`	`16`
`@@ -51,10 +50,7 @@ impl SuperStreamConsumerBuilder {`
`51`	`50`	`consumers.push(consumer);`
`52`	`51`	`}`
`53`	`52`
`54`		`- let super_stream_consumer_internal = Arc::new(SuperStreamConsumerInternal {`
`55`		`- offset_specification: self.offset_specification.clone(),`
`56`		`- consumers,`
`57`		`- });`
	`53`	`+ let super_stream_consumer_internal = Arc::new(SuperStreamConsumerInternal { consumers });`
`58`	`54`
`59`	`55`	`Ok(SuperStreamConsumer {`
`60`	`56`	`internal: super_stream_consumer_internal,`