pub struct GeminiToResponsesStream { /* private fields */ }Implementations§
Source§impl GeminiToResponsesStream
impl GeminiToResponsesStream
pub fn new( context: GeminiToResponsesContext, flow: IdentityFlow, limits: StreamLimits, ) -> Result<Self, TransformError>
pub fn new_with_policy( context: GeminiToResponsesContext, flow: IdentityFlow, policy: TargetIdPolicy, limits: StreamLimits, ) -> Result<Self, TransformError>
pub fn identities(&self) -> &IdentityFlow
pub fn push( &mut self, chunk: GenerateContentResponseBody, ) -> Result<Converted<Vec<StreamEvent>>, TransformError>
pub fn finish(self) -> Result<StreamEnd<StreamEvent>, TransformError>
Trait Implementations§
Source§impl StreamBridge for GeminiToResponsesStream
impl StreamBridge for GeminiToResponsesStream
type NativeEvent = GenerateContentResponseBody
type ClientEvent = StreamEvent
type NativeRequest = GenerateContentRequestBody
type ClientRequest = GenerateContentRequestBody
fn identities(&self) -> &IdentityFlow
fn push( &mut self, event: Self::NativeEvent, ) -> Result<Converted<Vec<Self::ClientEvent>>, TransformError>
fn finish(self) -> Result<BridgeEnd<Self::ClientEvent>, TransformError>
fn push_done(&mut self) -> Result<(), TransformError>
Auto Trait Implementations§
impl Freeze for GeminiToResponsesStream
impl RefUnwindSafe for GeminiToResponsesStream
impl Send for GeminiToResponsesStream
impl Sync for GeminiToResponsesStream
impl Unpin for GeminiToResponsesStream
impl UnsafeUnpin for GeminiToResponsesStream
impl UnwindSafe for GeminiToResponsesStream
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more