kvarn::prelude::networking::prelude::utils::prelude::compact_str::core::sync

Struct Exclusive

source
pub struct Exclusive<T>
where T: ?Sized,
{ /* private fields */ }
๐Ÿ”ฌThis is a nightly-only experimental API. (exclusive_wrapper)
Expand description

Exclusive provides only mutable access, also referred to as exclusive access to the underlying value. It provides no immutable, or shared access to the underlying value.

While this may seem not very useful, it allows Exclusive to unconditionally implement Sync. Indeed, the safety requirements of Sync state that for Exclusive to be Sync, it must be sound to share across threads, that is, it must be sound for &Exclusive to cross thread boundaries. By design, a &Exclusive has no API whatsoever, making it useless, thus harmless, thus memory safe.

Certain constructs like Futures can only be used with exclusive access, and are often Send but not Sync, so Exclusive can be used as hint to the Rust compiler that something is Sync in practice.

ยงExamples

Using a non-Sync future prevents the wrapping struct from being Sync

โ“˜
use core::cell::Cell;

async fn other() {}
fn assert_sync<T: Sync>(t: T) {}
struct State<F> {
    future: F
}

assert_sync(State {
    future: async {
        let cell = Cell::new(1);
        let cell_ref = &cell;
        other().await;
        let value = cell_ref.get();
    }
});

Exclusive ensures the struct is Sync without stripping the future of its functionality.

#![feature(exclusive_wrapper)]
use core::cell::Cell;
use core::sync::Exclusive;

async fn other() {}
fn assert_sync<T: Sync>(t: T) {}
struct State<F> {
    future: Exclusive<F>
}

assert_sync(State {
    future: Exclusive::new(async {
        let cell = Cell::new(1);
        let cell_ref = &cell;
        other().await;
        let value = cell_ref.get();
    })
});

ยงParallels with a mutex

In some sense, Exclusive can be thought of as a compile-time version of a mutex, as the borrow-checker guarantees that only one &mut can exist for any value. This is a parallel with the fact that & and &mut references together can be thought of as a compile-time version of a read-write lock.

Implementationsยง

sourceยง

impl<T> Exclusive<T>

source

pub const fn new(t: T) -> Exclusive<T> โ“˜

๐Ÿ”ฌThis is a nightly-only experimental API. (exclusive_wrapper)

Wrap a value in an Exclusive

source

pub const fn into_inner(self) -> T

๐Ÿ”ฌThis is a nightly-only experimental API. (exclusive_wrapper)

Unwrap the value contained in the Exclusive

sourceยง

impl<T> Exclusive<T>
where T: ?Sized,

source

pub const fn get_mut(&mut self) -> &mut T

๐Ÿ”ฌThis is a nightly-only experimental API. (exclusive_wrapper)

Gets exclusive access to the underlying value.

source

pub const fn get_pin_mut(self: Pin<&mut Exclusive<T>>) -> Pin<&mut T>

๐Ÿ”ฌThis is a nightly-only experimental API. (exclusive_wrapper)

Gets pinned exclusive access to the underlying value.

Exclusive is considered to structurally pin the underlying value, which means unpinned Exclusives can produce unpinned access to the underlying value, but pinned Exclusives only produce pinned access to the underlying value.

source

pub const fn from_mut(r: &mut T) -> &mut Exclusive<T> โ“˜

๐Ÿ”ฌThis is a nightly-only experimental API. (exclusive_wrapper)

Build a mutable reference to an Exclusive<T> from a mutable reference to a T. This allows you to skip building an Exclusive with Exclusive::new.

source

pub const fn from_pin_mut(r: Pin<&mut T>) -> Pin<&mut Exclusive<T>>

๐Ÿ”ฌThis is a nightly-only experimental API. (exclusive_wrapper)

Build a pinned mutable reference to an Exclusive<T> from a pinned mutable reference to a T. This allows you to skip building an Exclusive with Exclusive::new.

Trait Implementationsยง

sourceยง

impl<R, G> Coroutine<R> for Exclusive<G>
where G: Coroutine<R> + ?Sized,

sourceยง

type Yield = <G as Coroutine<R>>::Yield

๐Ÿ”ฌThis is a nightly-only experimental API. (coroutine_trait)
The type of value this coroutine yields. Read more
sourceยง

type Return = <G as Coroutine<R>>::Return

๐Ÿ”ฌThis is a nightly-only experimental API. (coroutine_trait)
The type of value this coroutine returns. Read more
sourceยง

fn resume( self: Pin<&mut Exclusive<G>>, arg: R, ) -> CoroutineState<<Exclusive<G> as Coroutine<R>>::Yield, <Exclusive<G> as Coroutine<R>>::Return>

๐Ÿ”ฌThis is a nightly-only experimental API. (coroutine_trait)
Resumes the execution of this coroutine. Read more
sourceยง

impl<T> Debug for Exclusive<T>
where T: ?Sized,

sourceยง

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

Formats the value using the given formatter. Read more
sourceยง

impl<T> Default for Exclusive<T>
where T: Default + ?Sized,

sourceยง

fn default() -> Exclusive<T> โ“˜

Returns the โ€œdefault valueโ€ for a type. Read more
sourceยง

impl<F, Args> FnMut<Args> for Exclusive<F>
where F: FnMut<Args>, Args: Tuple,

sourceยง

extern "rust-call" fn call_mut( &mut self, args: Args, ) -> <Exclusive<F> as FnOnce<Args>>::Output โ“˜

๐Ÿ”ฌThis is a nightly-only experimental API. (fn_traits)
Performs the call operation.
sourceยง

impl<F, Args> FnOnce<Args> for Exclusive<F>
where F: FnOnce<Args>, Args: Tuple,

sourceยง

type Output = <F as FnOnce<Args>>::Output

The returned type after the call operator is used.
sourceยง

extern "rust-call" fn call_once( self, args: Args, ) -> <Exclusive<F> as FnOnce<Args>>::Output โ“˜

๐Ÿ”ฌThis is a nightly-only experimental API. (fn_traits)
Performs the call operation.
sourceยง

impl<T> From<T> for Exclusive<T>

sourceยง

fn from(t: T) -> Exclusive<T> โ“˜

Converts to this type from the input type.
sourceยง

impl<T> Future for Exclusive<T>
where T: Future + ?Sized,

sourceยง

type Output = <T as Future>::Output

The type of value produced on completion.
sourceยง

fn poll( self: Pin<&mut Exclusive<T>>, cx: &mut Context<'_>, ) -> Poll<<Exclusive<T> as Future>::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available. Read more
sourceยง

impl<T> Sync for Exclusive<T>
where T: ?Sized,

Auto Trait Implementationsยง

ยง

impl<T> Freeze for Exclusive<T>
where T: Freeze + ?Sized,

ยง

impl<T> RefUnwindSafe for Exclusive<T>
where T: RefUnwindSafe + ?Sized,

ยง

impl<T> Send for Exclusive<T>
where T: Send + ?Sized,

ยง

impl<T> Unpin for Exclusive<T>
where T: Unpin + ?Sized,

ยง

impl<T> UnwindSafe for Exclusive<T>
where T: UnwindSafe + ?Sized,

Blanket Implementationsยง

sourceยง

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

sourceยง

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
sourceยง

impl<T> Borrow<T> for T
where T: ?Sized,

sourceยง

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
sourceยง

impl<T> BorrowMut<T> for T
where T: ?Sized,

sourceยง

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
ยง

impl<F> EventHandler for F
where F: FnMut(Result<Event, Error>) + Send + 'static,

ยง

fn handle_event(&mut self, event: Result<Event, Error>)

Handles an event.
sourceยง

impl<T> From<!> for T

sourceยง

fn from(t: !) -> T

Converts to this type from the input type.
sourceยง

impl<T> From<T> for T

sourceยง

fn from(t: T) -> T

Returns the argument unchanged.

ยง

impl<T> FutureExt for T
where T: Future + ?Sized,

ยง

fn map<U, F>(self, f: F) -> Map<Self, F> โ“˜
where F: FnOnce(Self::Output) -> U, Self: Sized,

Map this futureโ€™s output to a different type, returning a new future of the resulting type. Read more
ยง

fn map_into<U>(self) -> MapInto<Self, U> โ“˜
where Self::Output: Into<U>, Self: Sized,

Map this futureโ€™s output to a different type, returning a new future of the resulting type. Read more
ยง

fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> โ“˜
where F: FnOnce(Self::Output) -> Fut, Fut: Future, Self: Sized,

Chain on a computation for when a future finished, passing the result of the future to the provided closure f. Read more
ยง

fn left_future<B>(self) -> Either<Self, B> โ“˜
where B: Future<Output = Self::Output>, Self: Sized,

Wrap this future in an Either future, making it the left-hand variant of that Either. Read more
ยง

fn right_future<A>(self) -> Either<A, Self> โ“˜
where A: Future<Output = Self::Output>, Self: Sized,

Wrap this future in an Either future, making it the right-hand variant of that Either. Read more
ยง

fn into_stream(self) -> IntoStream<Self>
where Self: Sized,

Convert this future into a single element stream. Read more
ยง

fn flatten(self) -> Flatten<Self> โ“˜
where Self::Output: Future, Self: Sized,

Flatten the execution of this future when the output of this future is itself another future. Read more
ยง

fn flatten_stream(self) -> FlattenStream<Self>
where Self::Output: Stream, Self: Sized,

Flatten the execution of this future when the successful result of this future is a stream. Read more
ยง

fn fuse(self) -> Fuse<Self> โ“˜
where Self: Sized,

Fuse a future such that poll will never again be called once it has completed. This method can be used to turn any Future into a FusedFuture. Read more
ยง

fn inspect<F>(self, f: F) -> Inspect<Self, F> โ“˜
where F: FnOnce(&Self::Output), Self: Sized,

Do something with the output of a future before passing it on. Read more
ยง

fn catch_unwind(self) -> CatchUnwind<Self> โ“˜
where Self: Sized + UnwindSafe,

Available on crate feature std only.
Catches unwinding panics while polling the future. Read more
ยง

fn shared(self) -> Shared<Self> โ“˜
where Self: Sized, Self::Output: Clone,

Available on crate feature std only.
Create a cloneable handle to this future where all handles will resolve to the same result. Read more
ยง

fn remote_handle(self) -> (Remote<Self>, RemoteHandle<Self::Output>)
where Self: Sized,

Available on crate features channel and std only.
Turn this future into a future that yields () on completion and sends its output to another future on a separate task. Read more
ยง

fn boxed<'a>(self) -> Pin<Box<dyn Future<Output = Self::Output> + Send + 'a>>
where Self: Sized + Send + 'a,

Available on crate feature alloc only.
Wrap the future in a Box, pinning it. Read more
ยง

fn boxed_local<'a>(self) -> Pin<Box<dyn Future<Output = Self::Output> + 'a>>
where Self: Sized + 'a,

Available on crate feature alloc only.
Wrap the future in a Box, pinning it. Read more
ยง

fn unit_error(self) -> UnitError<Self> โ“˜
where Self: Sized,

ยง

fn never_error(self) -> NeverError<Self> โ“˜
where Self: Sized,

ยง

fn poll_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Self::Output>
where Self: Unpin,

A convenience for calling Future::poll on Unpin future types.
ยง

fn now_or_never(self) -> Option<Self::Output>
where Self: Sized,

Evaluates and consumes the future, returning the resulting output if the future is ready after the first call to Future::poll. Read more
ยง

impl<T> Instrument for T

ยง

fn instrument(self, span: Span) -> Instrumented<Self> โ“˜

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
ยง

fn in_current_span(self) -> Instrumented<Self> โ“˜

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
sourceยง

impl<T, U> Into<U> for T
where U: From<T>,

sourceยง

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

sourceยง

impl<F> IntoFuture for F
where F: Future,

sourceยง

type Output = <F as Future>::Output

The output that the future will produce on completion.
sourceยง

type IntoFuture = F

Which kind of future are we turning this into?
sourceยง

fn into_future(self) -> <F as IntoFuture>::IntoFuture

Creates a future from a value. Read more
ยง

impl<'a, I, O, E, F> Parser<I, O, E> for F
where F: FnMut(I) -> Result<(I, O), Err<E>> + 'a,

ยง

fn parse(&mut self, i: I) -> Result<(I, O), Err<E>>

A parser takes in input type, and returns a Result containing either the remaining input and the output value, or an error
ยง

fn map<G, O2>(self, g: G) -> Map<Self, G, O>
where G: Fn(O) -> O2, Self: Sized,

Maps a function over the result of a parser
ยง

fn flat_map<G, H, O2>(self, g: G) -> FlatMap<Self, G, O>
where G: FnMut(O) -> H, H: Parser<I, O2, E>, Self: Sized,

Creates a second parser from the output of the first one, then apply over the rest of the input
ยง

fn and_then<G, O2>(self, g: G) -> AndThen<Self, G, O>
where G: Parser<O, O2, E>, Self: Sized,

Applies a second parser over the output of the first one
ยง

fn and<G, O2>(self, g: G) -> And<Self, G>
where G: Parser<I, O2, E>, Self: Sized,

Applies a second parser after the first one, return their results as a tuple
ยง

fn or<G>(self, g: G) -> Or<Self, G>
where G: Parser<I, O, E>, Self: Sized,

Applies a second parser over the input if the first one failed
ยง

fn into<O2, E2>(self) -> Into<Self, O, O2, E, E2>
where O2: From<O>, E2: From<E>, Self: Sized,

automatically converts the parserโ€™s output and error values to another type, as long as they implement the From trait
sourceยง

impl<F> Pattern for F
where F: FnMut(char) -> bool,

sourceยง

type Searcher<'a> = CharPredicateSearcher<'a, F>

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Associated searcher for this pattern
sourceยง

fn into_searcher<'a>(self, haystack: &'a str) -> CharPredicateSearcher<'a, F>

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Constructs the associated searcher from self and the haystack to search in.
sourceยง

fn is_contained_in<'a>(self, haystack: &'a str) -> bool

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Checks whether the pattern matches anywhere in the haystack
sourceยง

fn is_prefix_of<'a>(self, haystack: &'a str) -> bool

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Checks whether the pattern matches at the front of the haystack
sourceยง

fn strip_prefix_of<'a>(self, haystack: &'a str) -> Option<&'a str>

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Removes the pattern from the front of haystack, if it matches.
sourceยง

fn is_suffix_of<'a>(self, haystack: &'a str) -> bool

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Checks whether the pattern matches at the back of the haystack
sourceยง

fn strip_suffix_of<'a>(self, haystack: &'a str) -> Option<&'a str>

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Removes the pattern from the back of haystack, if it matches.
sourceยง

fn as_utf8_pattern(&self) -> Option<Utf8Pattern<'_>>

๐Ÿ”ฌThis is a nightly-only experimental API. (pattern)
Returns the pattern as utf-8 bytes if possible.
ยง

impl<T> Pointable for T

ยง

const ALIGN: usize = _

The alignment of pointer.
ยง

type Init = T

The type for initializers.
ยง

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
ยง

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
ยง

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
ยง

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
sourceยง

impl<T> Same for T

sourceยง

type Output = T

Should always be Self
ยง

impl<F> ScanEventHandler for F
where F: FnMut(Result<PathBuf, Error>) + Send + 'static,

ยง

fn handle_event(&mut self, event: Result<PathBuf, Error>)

Handles an event.
sourceยง

impl<T, U> TryFrom<U> for T
where U: Into<T>,

sourceยง

type Error = Infallible

The type returned in the event of a conversion error.
sourceยง

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
ยง

impl<F, T, E> TryFuture for F
where F: Future<Output = Result<T, E>> + ?Sized,

ยง

type Ok = T

The type of successful values yielded by this future
ยง

type Error = E

The type of failures yielded by this future
ยง

fn try_poll( self: Pin<&mut F>, cx: &mut Context<'_>, ) -> Poll<<F as Future>::Output>

Poll this TryFuture as if it were a Future. Read more
ยง

impl<Fut> TryFutureExt for Fut
where Fut: TryFuture + ?Sized,

ยง

fn flatten_sink<Item>(self) -> FlattenSink<Self, Self::Ok>
where Self::Ok: Sink<Item, Error = Self::Error>, Self: Sized,

Available on crate feature sink only.
Flattens the execution of this future when the successful result of this future is a Sink. Read more
ยง

fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> โ“˜
where F: FnOnce(Self::Ok) -> T, Self: Sized,

Maps this futureโ€™s success value to a different value. Read more
ยง

fn map_ok_or_else<T, E, F>(self, e: E, f: F) -> MapOkOrElse<Self, F, E> โ“˜
where F: FnOnce(Self::Ok) -> T, E: FnOnce(Self::Error) -> T, Self: Sized,

Maps this futureโ€™s success value to a different value, and permits for error handling resulting in the same type. Read more
ยง

fn map_err<E, F>(self, f: F) -> MapErr<Self, F> โ“˜
where F: FnOnce(Self::Error) -> E, Self: Sized,

Maps this futureโ€™s error value to a different value. Read more
ยง

fn err_into<E>(self) -> ErrInto<Self, E> โ“˜
where Self: Sized, Self::Error: Into<E>,

Maps this futureโ€™s Error to a new error type using the Into trait. Read more
ยง

fn ok_into<U>(self) -> OkInto<Self, U> โ“˜
where Self: Sized, Self::Ok: Into<U>,

Maps this futureโ€™s Ok to a new type using the Into trait.
ยง

fn and_then<Fut, F>(self, f: F) -> AndThen<Self, Fut, F> โ“˜
where F: FnOnce(Self::Ok) -> Fut, Fut: TryFuture<Error = Self::Error>, Self: Sized,

Executes another future after this one resolves successfully. The success value is passed to a closure to create this subsequent future. Read more
ยง

fn or_else<Fut, F>(self, f: F) -> OrElse<Self, Fut, F> โ“˜
where F: FnOnce(Self::Error) -> Fut, Fut: TryFuture<Ok = Self::Ok>, Self: Sized,

Executes another future if this one resolves to an error. The error value is passed to a closure to create this subsequent future. Read more
ยง

fn inspect_ok<F>(self, f: F) -> InspectOk<Self, F> โ“˜
where F: FnOnce(&Self::Ok), Self: Sized,

Do something with the success value of a future before passing it on. Read more
ยง

fn inspect_err<F>(self, f: F) -> InspectErr<Self, F> โ“˜
where F: FnOnce(&Self::Error), Self: Sized,

Do something with the error value of a future before passing it on. Read more
ยง

fn try_flatten(self) -> TryFlatten<Self, Self::Ok> โ“˜
where Self::Ok: TryFuture<Error = Self::Error>, Self: Sized,

Flatten the execution of this future when the successful result of this future is another future. Read more
ยง

fn try_flatten_stream(self) -> TryFlattenStream<Self>
where Self::Ok: TryStream<Error = Self::Error>, Self: Sized,

Flatten the execution of this future when the successful result of this future is a stream. Read more
ยง

fn unwrap_or_else<F>(self, f: F) -> UnwrapOrElse<Self, F> โ“˜
where Self: Sized, F: FnOnce(Self::Error) -> Self::Ok,

Unwraps this futureโ€™s output, producing a future with this futureโ€™s Ok type as its Output type. Read more
ยง

fn into_future(self) -> IntoFuture<Self> โ“˜
where Self: Sized,

Wraps a [TryFuture] into a type that implements Future. Read more
ยง

fn try_poll_unpin( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::Ok, Self::Error>>
where Self: Unpin,

A convenience method for calling [TryFuture::try_poll] on Unpin future types.
sourceยง

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

sourceยง

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

The type returned in the event of a conversion error.
sourceยง

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
ยง

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

ยง

fn vzip(self) -> V

ยง

impl<F> Visit for F
where F: FnMut(&Field, &dyn Debug),

ยง

fn record_debug(&mut self, field: &Field, value: &dyn Debug)

Visit a value implementing fmt::Debug.
ยง

fn record_f64(&mut self, field: &Field, value: f64)

Visit a double-precision floating point value.
ยง

fn record_i64(&mut self, field: &Field, value: i64)

Visit a signed 64-bit integer value.
ยง

fn record_u64(&mut self, field: &Field, value: u64)

Visit an unsigned 64-bit integer value.
ยง

fn record_i128(&mut self, field: &Field, value: i128)

Visit a signed 128-bit integer value.
ยง

fn record_u128(&mut self, field: &Field, value: u128)

Visit an unsigned 128-bit integer value.
ยง

fn record_bool(&mut self, field: &Field, value: bool)

Visit a boolean value.
ยง

fn record_str(&mut self, field: &Field, value: &str)

Visit a string value.
ยง

fn record_error(&mut self, field: &Field, value: &(dyn Error + 'static))

Available on crate feature std only.
Records a type implementing Error. Read more
ยง

impl<T> WithSubscriber for T

ยง

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> โ“˜
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
ยง

fn with_current_subscriber(self) -> WithDispatch<Self> โ“˜

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more