Struct MutableConnection

pub struct MutableConnection<DirectoryType: MutableDirectory> { /* private fields */ }

Implementations

impl<DirectoryType: MutableDirectory> MutableConnection<DirectoryType>

pub async fn create( scope: ExecutionScope, directory: Arc<DirectoryType>, protocols: impl ProtocolsExt, object_request: ObjectRequestRef<'_>, ) -> Result<(), Status>

Creates a new connection to serve the mutable directory. The directory will be served from a new async Task, not from the current Task. Errors in constructing the connection are not guaranteed to be returned, they may be sent directly to the client end of the connection. This method should be called from within an ObjectRequest handler to ensure that errors are sent to the client end of the connection.

Trait Implementations

impl<DirectoryType: MutableDirectory> ConnectionCreator<DirectoryType> for MutableConnection<DirectoryType>

async fn create<'a>( scope: ExecutionScope, node: Arc<DirectoryType>, protocols: impl ProtocolsExt, object_request: ObjectRequestRef<'a>, ) -> Result<(), Status>

Creates a new connection to node and spawns a new Task to run the connection.

impl<DirectoryType: MutableDirectory> TokenInterface for MutableConnection<DirectoryType>

fn get_node(&self) -> Arc<dyn MutableDirectory>

Returns the node and flags that correspond with this token. This information is returned by the get_owner method. For now this always returns Arc but it should be possible to change this so that files can be represented in future if and when the need arises.

fn token_registry(&self) -> &TokenRegistry

Returns the token registry.