Struct ImmutableConnection

pub struct ImmutableConnection<DirectoryType: Directory> { /* private fields */ }

Implementations

impl<DirectoryType: Directory> ImmutableConnection<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 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.

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

where Transform: FnOnce(DirectoryRequestStream) -> RS, RS: Stream<Item = Result<DirectoryRequest, Error>> + Send + 'static,

TODO(https://fxbug.dev/326626515): this is an experimental method to run a FIDL directory connection until stalled, with the purpose to cleanly stop a component. We’ll expect to revisit how this works to generalize to all connections later. Try not to use this function for other purposes.

Trait Implementations

impl<DirectoryType: Directory> ConnectionCreator<DirectoryType> for ImmutableConnection<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.