pub struct ApiCaller<W: Write + Unpin> { /* private fields */ }
Implementations
sourceimpl<W: Write + Unpin> ApiCaller<W>
impl<W: Write + Unpin> ApiCaller<W>
pub fn new(rpc: RpcWriter<W>) -> Self
pub fn rpc(&mut self) -> &mut RpcWriter<W>
sourcepub async fn invite_create_req_send(&mut self, uses: u16) -> Result<RequestNo>
pub async fn invite_create_req_send(&mut self, uses: u16) -> Result<RequestNo>
Send [“invite”, “create”] request.
sourcepub async fn invite_use_req_send(
&mut self,
invite_code: &str
) -> Result<RequestNo>
pub async fn invite_use_req_send(
&mut self,
invite_code: &str
) -> Result<RequestNo>
Send [“invite”, “use”] request.
sourcepub async fn friends_is_following_req_send(
&mut self,
args: RelationshipQuery
) -> Result<RequestNo>
pub async fn friends_is_following_req_send(
&mut self,
args: RelationshipQuery
) -> Result<RequestNo>
Send [“friends”, “isFollowing”] request.
sourcepub async fn friends_is_blocking_req_send(
&mut self,
args: RelationshipQuery
) -> Result<RequestNo>
pub async fn friends_is_blocking_req_send(
&mut self,
args: RelationshipQuery
) -> Result<RequestNo>
Send [“friends”, “isBlocking”] request.
sourcepub async fn friends_hops_req_send(
&mut self,
args: FriendsHops
) -> Result<RequestNo>
pub async fn friends_hops_req_send(
&mut self,
args: FriendsHops
) -> Result<RequestNo>
Send [“friends”, “hops”] request
sourcepub async fn getsubset_req_send(
&mut self,
query: SubsetQuery,
opts: Option<SubsetQueryOptions>
) -> Result<RequestNo>
pub async fn getsubset_req_send(
&mut self,
query: SubsetQuery,
opts: Option<SubsetQueryOptions>
) -> Result<RequestNo>
Send [“partialReplication”, “getSubset”] request.
sourcepub async fn publish_req_send(&mut self, msg: TypedMessage) -> Result<RequestNo>
pub async fn publish_req_send(&mut self, msg: TypedMessage) -> Result<RequestNo>
Send [“publish”] request.
sourcepub async fn publish_res_send(
&mut self,
req_no: RequestNo,
msg_ref: String
) -> Result<()>
pub async fn publish_res_send(
&mut self,
req_no: RequestNo,
msg_ref: String
) -> Result<()>
Send [“publish”] response.
sourcepub async fn whoami_req_send(&mut self) -> Result<RequestNo>
pub async fn whoami_req_send(&mut self) -> Result<RequestNo>
Send [“whoami”] request.
sourcepub async fn whoami_res_send(
&mut self,
req_no: RequestNo,
id: String
) -> Result<()>
pub async fn whoami_res_send(
&mut self,
req_no: RequestNo,
id: String
) -> Result<()>
Send [“whoami”] response.
sourcepub async fn get_req_send(&mut self, msg_id: &str) -> Result<RequestNo>
pub async fn get_req_send(&mut self, msg_id: &str) -> Result<RequestNo>
Send [“get”] request.
sourcepub async fn get_res_send(
&mut self,
req_no: RequestNo,
msg: &Message
) -> Result<()>
pub async fn get_res_send(
&mut self,
req_no: RequestNo,
msg: &Message
) -> Result<()>
Send [“get”] response.
sourcepub async fn create_history_stream_req_send(
&mut self,
args: &CreateHistoryStreamIn
) -> Result<RequestNo>
pub async fn create_history_stream_req_send(
&mut self,
args: &CreateHistoryStreamIn
) -> Result<RequestNo>
Send [“createHistoryStream”] request.
sourcepub async fn create_feed_stream_req_send<'a>(
&mut self,
args: &CreateStreamIn<u64>
) -> Result<RequestNo>
pub async fn create_feed_stream_req_send<'a>(
&mut self,
args: &CreateStreamIn<u64>
) -> Result<RequestNo>
Send [“createFeedStream”] request.
sourcepub async fn latest_req_send(&mut self) -> Result<RequestNo>
pub async fn latest_req_send(&mut self) -> Result<RequestNo>
Send [“latest”] request.
sourcepub async fn blobs_get_req_send(
&mut self,
args: &BlobsGetIn
) -> Result<RequestNo>
pub async fn blobs_get_req_send(
&mut self,
args: &BlobsGetIn
) -> Result<RequestNo>
Send [“blobs”,“get”] request.
sourcepub async fn feed_res_send(
&mut self,
req_no: RequestNo,
feed: &str
) -> Result<()>
pub async fn feed_res_send(
&mut self,
req_no: RequestNo,
feed: &str
) -> Result<()>
Send feed response
sourcepub async fn blob_create_wants_req_send(&mut self) -> Result<RequestNo>
pub async fn blob_create_wants_req_send(&mut self) -> Result<RequestNo>
Send blob create wants
Auto Trait Implementations
impl<W> RefUnwindSafe for ApiCaller<W> where
W: RefUnwindSafe,
impl<W> Send for ApiCaller<W> where
W: Send,
impl<W> Sync for ApiCaller<W> where
W: Sync,
impl<W> Unpin for ApiCaller<W>
impl<W> UnwindSafe for ApiCaller<W> where
W: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more