Struct TestTransport 

pub struct TestTransport { /* private fields */ }

Implementations

impl TestTransport

pub fn new() -> Self

pub fn handle(&self) -> TestTransportHandle

pub fn push_http_response(&self, response: CombinedResponse)

pub fn push_http_response_fn<F>(&self, response_fn: F)

where F: Fn(&CombinedRequest) -> Result<CombinedResponse> + Send + Sync + 'static,

pub fn push_ws_push_response(&self, response: PushCommitResponse)

pub fn push_realtime_event(&self, event: RealtimeEvent)

pub fn push_snapshot_chunk_rows(&self, rows: Vec<Value>)

pub fn push_snapshot_artifact_bytes(&self, bytes: Vec<u8>)

pub fn seed_blob(&self, blob: &BlobRef, bytes: Vec<u8>)

Trait Implementations

impl BlobTransport for TestTransport

fn upload_blob(&self, blob: &BlobRef, bytes: &[u8]) -> Result<()>

fn download_blob(&self, blob: &BlobRef) -> Result<Vec<u8>>

fn upload_blob_file( &self, blob: &BlobRef, path: &Path, ) -> Result<(), SyncularError>

fn download_blob_to_file( &self, blob: &BlobRef, path: &Path, ) -> Result<(), SyncularError>

impl Clone for TestTransport

fn clone(&self) -> TestTransport

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TestTransport

fn default() -> TestTransport

Returns the “default value” for a type.

impl SyncAuthHeaderStore for TestTransport

fn set_auth_headers(&mut self, headers: SyncAuthHeaders)

impl SyncTransport for TestTransport

type Realtime = TestRealtime

fn post_sync(&self, request: &CombinedRequest) -> Result<CombinedResponse>

fn fetch_snapshot_chunk_rows( &self, chunk: &SnapshotChunkRef, scopes: &Map<String, Value>, ) -> Result<SnapshotChunkRows>

fn fetch_snapshot_artifact_bytes( &self, artifact: &ScopedSnapshotArtifactRef, scopes: &Map<String, Value>, ) -> Result<Vec<u8>>

fn connect_realtime(&self) -> Result<Self::Realtime>