[−][src]Struct sync15::request::PostQueue

pub struct PostQueue<Post, OnResponse> {
    poster: Post,
    on_response: OnResponse,
    post_limits: LimitTracker,
    batch_limits: LimitTracker,
    max_payload_bytes: usize,
    max_request_bytes: usize,
    queued: Vec<u8>,
    batch: BatchState,
    last_modified: ServerTimestamp,
}

Fields

poster: Poston_response: OnResponsepost_limits: LimitTrackerbatch_limits: LimitTrackermax_payload_bytes: usizemax_request_bytes: usizequeued: Vec<u8>batch: BatchStatelast_modified: ServerTimestamp

Implementations

impl<Poster, OnResponse> PostQueue<Poster, OnResponse> where
    Poster: BatchPoster,
    OnResponse: PostResponseHandler, [src]

pub fn new(
    config: &InfoConfiguration,
    ts: ServerTimestamp,
    poster: Poster,
    on_response: OnResponse
) -> PostQueue<Poster, OnResponse>[src]

fn in_batch(&self) -> bool[src]

pub fn enqueue(&mut self, record: &EncryptedBso) -> Result<bool>[src]

pub fn flush(&mut self, want_commit: bool) -> Result<()>[src]

impl<Poster> PostQueue<Poster, NormalResponseHandler>[src]

pub fn completed_upload_info(&mut self) -> UploadInfo[src]

Trait Implementations

impl<Post: Debug, OnResponse: Debug> Debug for PostQueue<Post, OnResponse>[src]

Auto Trait Implementations

impl<Post, OnResponse> RefUnwindSafe for PostQueue<Post, OnResponse> where
    OnResponse: RefUnwindSafe,
    Post: RefUnwindSafe, 

impl<Post, OnResponse> Send for PostQueue<Post, OnResponse> where
    OnResponse: Send,
    Post: Send, 

impl<Post, OnResponse> Sync for PostQueue<Post, OnResponse> where
    OnResponse: Sync,
    Post: Sync, 

impl<Post, OnResponse> Unpin for PostQueue<Post, OnResponse> where
    OnResponse: Unpin,
    Post: Unpin, 

impl<Post, OnResponse> UnwindSafe for PostQueue<Post, OnResponse> where
    OnResponse: UnwindSafe,
    Post: UnwindSafe, 

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,