Skip to content

Commit ac4bde3

Browse files
committed
syntax fix
1 parent 12e2de8 commit ac4bde3

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

crates/iceberg/src/writer/file_writer/rolling_writer.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -111,13 +111,14 @@ impl<B: FileWriterBuilder> FileWriter for RollingFileWriter<B> {
111111
}
112112

113113
// write the input
114-
let Some(writer) = self.inner.as_mut() else {
114+
if let Some(writer) = self.inner.as_mut() {
115+
writer.write(input).await?;
116+
} else {
115117
return Err(Error::new(
116118
ErrorKind::Unexpected,
117119
"Writer is not initialized!",
118120
));
119121
};
120-
writer.write(input).await?;
121122

122123
Ok(())
123124
}

0 commit comments

Comments
 (0)