pub struct DurableStreamReader { /* private fields */ }Expand description
Immutable read descriptor. Construction records no HTTP effect and captures the secret’s pinned identity, not its plaintext or the borrowed handle.
Implementations§
Source§impl DurableStreamReader
impl DurableStreamReader
pub fn new(options: &DurableStreamReaderOptions, auth: Option<&Secret>) -> Self
Source§impl DurableStreamReader
impl DurableStreamReader
Sourcepub async fn read(
&self,
request: DurableStreamReadRequest,
) -> Result<DurableStreamBatch, DurableStreamError>
pub async fn read( &self, request: DurableStreamReadRequest, ) -> Result<DurableStreamBatch, DurableStreamError>
One protocol attempt. Replay returns the recorded batch without HTTP.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for DurableStreamReader
impl RefUnwindSafe for DurableStreamReader
impl Send for DurableStreamReader
impl Sync for DurableStreamReader
impl Unpin for DurableStreamReader
impl UnsafeUnpin for DurableStreamReader
impl UnwindSafe for DurableStreamReader
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