Struct ResponsesToChatStream 

pub struct ResponsesToChatStream { /* private fields */ }

Each push returns only newly emitted target chunks. Source item/part order is retained when concurrent Responses messages feed Chat’s single content field.

Implementations

impl ResponsesToChatStream

pub fn new(flow: IdentityFlow, limits: StreamLimits) -> Self

pub fn new_with_policy( flow: IdentityFlow, limits: StreamLimits, policy: TargetIdPolicy, ) -> Result<Self, TransformError>

pub fn identities(&self) -> &IdentityFlow

pub fn push( &mut self, event: StreamEvent, ) -> Result<Converted<Vec<ChatCompletionChunk>>, TransformError>

pub fn finish(self) -> Result<StreamEnd<ChatCompletionChunk>, TransformError>

Trait Implementations

impl FanoutBridge for ResponsesToChatStream

fn reserve( &mut self, role: IdentityRole, ids: &BTreeSet<String>, ) -> Result<(), TransformError>

impl StreamBridge for ResponsesToChatStream

type NativeEvent = StreamEvent

type ClientEvent = ChatCompletionChunk

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>