Struct Handles 

struct Handles<S: Server> {
    actix_server_handle: ServerHandle,
    actix_join_handle: JoinHandle<Result<(), Error>>,
    ph_join_handle: JoinHandle<Result<Option<Box<dyn Modifier<S>>>>>,
    ph_shutdown_sender: Option<Sender<Infallible>>,
    command_receiver: Receiver<CommandRequest<S>>,
    drop_bomb: Bomb,
}

The handles to control an actix_web::dev::Server running a pubhubs Server.

Fields

actix_server_handle: ServerHandle

Handle to the actual actix TCP server. The actix_web::dev::Server is owned by the task driving it.

actix_join_handle: JoinHandle<Result<(), Error>>

Handle to the task driving the actix TCP server

ph_join_handle: JoinHandle<Result<Option<Box<dyn Modifier<S>>>>>

Handle to the task running (discovery for) the PubHubs server.

ph_shutdown_sender: Option<Sender<Infallible>>

Dropped to order ph_join_handle to shutdown. None when used.

command_receiver: Receiver<CommandRequest<S>>

Receives commands from the Apps

drop_bomb: Bomb

To check whether Handles::shutdown was completed before being dropped

Implementations

impl<S: Server> Handles<S>

async fn run_until_command( &mut self, runner: &mut Runner<S>, ) -> Result<Command<S>>

Drives the actix server until a Command is received - which is returned

async fn shutdown(self) -> Result<()>

Consumes this Handles shutting down the actix server and pubhubs tasks.