diff --git a/arrow-flight/src/sql/mod.rs b/arrow-flight/src/sql/mod.rs index 8e8515bc610..7056c4b6ee0 100644 --- a/arrow-flight/src/sql/mod.rs +++ b/arrow-flight/src/sql/mod.rs @@ -122,10 +122,10 @@ pub trait ProstAnyExt { /// /// * `Ok(None)` when message type mismatch /// * `Err` when parse failed - fn unpack(&self) -> ArrowResult>; + fn unpack(&self) -> Result, ArrowError>; /// Pack any message into `prost_types::Any` value. - fn pack(message: &M) -> ArrowResult; + fn pack(message: &M) -> Result; } impl ProstAnyExt for prost_types::Any { @@ -133,7 +133,7 @@ impl ProstAnyExt for prost_types::Any { M::type_url() == self.type_url } - fn unpack(&self) -> ArrowResult> { + fn unpack(&self) -> Result, ArrowError> { if !self.is::() { return Ok(None); } @@ -143,7 +143,7 @@ impl ProstAnyExt for prost_types::Any { Ok(Some(m)) } - fn pack(message: &M) -> ArrowResult { + fn pack(message: &M) -> Result { Ok(message.as_any()) } }