Skip to content

Commit 6d679e2

Browse files
Provide access for wrapped builder (#717)
1 parent c676389 commit 6d679e2

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

timely/src/dataflow/operators/generic/handles.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,9 @@ pub struct Session<'a: 'b, 'b, T: Timestamp, CB: ContainerBuilder, CT: Capabilit
176176

177177
impl<'a: 'b, 'b, T: Timestamp, CB: ContainerBuilder, CT: CapabilityTrait<T>> Session<'a, 'b, T, CB, CT> {
178178

179+
/// Provides access to the underlying container builder.
180+
pub fn builder(&mut self) -> &mut CB { &mut self.buffer.builder }
181+
179182
/// Provides one record at the time specified by the `Session`.
180183
#[inline] pub fn give<D>(&mut self, data: D) where CB: PushInto<D> {
181184
self.buffer.builder.push_into(data);

0 commit comments

Comments
 (0)