Struct PullSourceProxy

pub struct PullSourceProxy { /* private fields */ }

Implementations

impl PullSourceProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.time.external/PullSource.

pub fn take_event_stream(&self) -> PullSourceEventStream

Get a Stream of events from the remote end of the protocol.

Panics

Panics if the event stream was already taken.

pub fn update_device_properties( &self, properties: &Properties, ) -> Result<(), Error>

Notifies the time source of changes to global properties of the device that it may use to increase accuracy of time measurements.

pub fn sample( &self, urgency: Urgency, ) -> QueryResponseFut<PullSourceSampleResult, DefaultFuchsiaResourceDialect>

Produce a new time sample.

The server may consider the supplied urgency and will potentially produce a sample more quickly but with lower accuracy when a request is marked urgent.

The server will return an error for permanent errors but will block on conditions that are not known to be permanent (e.g. network not connected).

The server will return a RATE_LIMITED error if the client should wait before requesting another sample. In this case the client may call NextPossibleSampleTime to determine when the time source will be willing to produce another sample.

pub fn next_possible_sample_time( &self, ) -> QueryResponseFut<i64, DefaultFuchsiaResourceDialect>

Returns the monotonic time at which the PullSource is willing to produce another sample. If the PullSource is not rate limited it will return a time less than or equal to current monotonic time.

Trait Implementations

impl Clone for PullSourceProxy

fn clone(&self) -> PullSourceProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PullSourceProxy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Proxy for PullSourceProxy

type Protocol = PullSourceMarker

The protocol which this Proxy controls.

fn from_channel(inner: AsyncChannel) -> Self

Create a proxy over the given channel.

fn into_channel(self) -> Result<AsyncChannel, Self>

Attempt to convert the proxy back into a channel.

fn as_channel(&self) -> &AsyncChannel

Get a reference to the proxy’s underlying channel.

fn into_client_end(self) -> Result<ClientEnd<Self::Protocol>, Self>

Attempt to convert the proxy back into a client end.

fn is_closed(&self) -> bool

Returns true if the proxy has received the PEER_CLOSED signal.

fn on_closed(&self) -> OnSignals<'_, Unowned<'_, Handle>>

Returns a future that completes when the proxy receives the PEER_CLOSED signal.

impl PullSourceProxyInterface for PullSourceProxy

type SampleResponseFut = QueryResponseFut<Result<TimeSample, Error>>

type NextPossibleSampleTimeResponseFut = QueryResponseFut<i64>

fn update_device_properties(&self, properties: &Properties) -> Result<(), Error>

fn sample(&self, urgency: Urgency) -> Self::SampleResponseFut

fn next_possible_sample_time(&self) -> Self::NextPossibleSampleTimeResponseFut