pub struct ResponseStream { /* private fields */ }Implementations§
Source§impl ResponseStream
impl ResponseStream
pub fn new( source: OperationKey, target: OperationKey, ) -> Result<Self, TransformError>
pub fn new_framed( source: OperationKey, target: OperationKey, source_framing: StreamFraming, target_framing: StreamFraming, ) -> Result<Self, TransformError>
pub fn push(&mut self, chunk: Bytes) -> Result<Vec<Bytes>, TransformError>
pub fn finish(&mut self) -> Result<Vec<Bytes>, TransformError>
Auto Trait Implementations§
impl !RefUnwindSafe for ResponseStream
impl !Sync for ResponseStream
impl !UnwindSafe for ResponseStream
impl Freeze for ResponseStream
impl Send for ResponseStream
impl Unpin for ResponseStream
impl UnsafeUnpin for ResponseStream
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