pub async fn run(&self, socket: &mut TcpStream) -> Result<(), ObjectSendError> {
        // try to send objects and handle any resulting errors
        if let Err(err) = self.send_objects(socket).await {
            // errors which can happen only before any objects are sent will have a response code
            if let Some(response_code) = err.response_code() {
                // if we couldn't send a response code for some reason, there isn't much
                // else we can do - so, just ignore the error
                let _result = socket.write_u8(response_code).await;
            }
            return Err(err);
        }
        Ok(())
    }
/// Reads objects from the local plasma store and sends them into the specified socket. If
/// `delete_after_send` = true, it'll try to delete the objects from the store after they
/// are sent. However, deletion of the objects from the local store is not guaranteed.
///
/// Will return an error if:
/// * Any of the requested objects are scheduled for deletion.
/// * Any of the requested objects were not found in the local Plasma Store.
/// * There was some kind of error retrieving objects from the Plasma Store.
/// * Any of the requested objects exceed data and metadata size limits.
/// * Writing objects into the socket fails for some reason; this error may happen after
///   some objects have already been written into the socket.
Reads objects from the local plasma store and sends them into the specified socket. If
`delete_after_send` = true, it'll try to delete the objects from the store after they
are sent. However, deletion of the objects from the local store is not guaranteed.

Will return an error if:
Any of the requested objects are scheduled for deletion.
Any of the requested objects were not found in the local Plasma Store.
There was some kind of error retrieving objects from the Plasma Store.
Any of the requested objects exceed data and metadata size limits.
Writing objects into the socket fails for some reason; this error may happen after
some objects have already been written into the socket.
Reads objects from the local plasma store and sends them into the specified socket . If ` delete_after_send ` = true it ' ll try to delete the objects from the store after they are sent . However deletion of the objects from the local store is not guaranteed . Will return an error if : Any of the requested objects are scheduled for deletion . Any of the requested objects were not found in the local Plasma Store . There was some kind of error retrieving objects from the Plasma Store . Any of the requested objects exceed data and metadata size limits . Writing objects into the socket fails for some reason ; this error may happen after some objects have already been written into the socket .
pub async fn run(&self, socket: &mut TcpStream) -> Result<(), ObjectSendError> {
        // try to send objects and handle any resulting errors
        if let Err(err) = self.send_objects(socket).await {
            // errors which can happen only before any objects are sent will have a response code
            if let Some(response_code) = err.response_code() {
                // if we couldn't send a response code for some reason, there isn't much
                // else we can do - so, just ignore the error
                let _result = socket.write_u8(response_code).await;
            }
            return Err(err);
        }
        Ok(())
    }
pub async fn run ( & self , socket : & mut TcpStream ) -> Result < ( ) , ObjectSendError > { // try to send objects and handle any resulting errors if let Err ( err ) = self . send_objects ( socket ) . await { // errors which can happen only before any objects are sent will have a response code if let Some ( response_code ) = err . response_code ( ) { // if we couldn't send a response code for some reason, there isn't much // else we can do - so, just ignore the error let _result = socket . write_u8 ( response_code ) . await ; } return Err ( err ) ; } Ok ( ( ) ) }
Reads objects from the local plasma store and sends them into the specified socket.
Reads objects from the local plasma store and sends them into the specified socket .
&self
socket
&mut TcpStream
&self
socket
&mut TcpStream