pub struct StreamGroupReader {
pub info: Arc<StreamGroup>,
/* private fields */
}
Fields§
§info: Arc<StreamGroup>
Implementations§
Source§impl StreamGroupReader
impl StreamGroupReader
pub async fn read_next(&mut self) -> Result<Option<Bytes>, ServeError>
pub async fn next(&mut self) -> Result<Option<StreamObjectReader>, ServeError>
pub fn latest(&self) -> u64
Trait Implementations§
Source§impl Clone for StreamGroupReader
impl Clone for StreamGroupReader
Source§fn clone(&self) -> StreamGroupReader
fn clone(&self) -> StreamGroupReader
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl Freeze for StreamGroupReader
impl RefUnwindSafe for StreamGroupReader
impl Send for StreamGroupReader
impl Sync for StreamGroupReader
impl Unpin for StreamGroupReader
impl UnwindSafe for StreamGroupReader
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