Struct Watching 

pub struct Watching;

Trait Implementations

impl Operation for Watching

type Declaration = Watch

type Resources = ()

type Error = Error

type Context<'a> = Context<'a>

type Endpoints = StreamOutput<InstanceState, Error>

async fn initialize<'ctx>(_: Arc<()>, _: Self::Context<'ctx>) -> Result<Self>

async fn run<'ctx>( &mut self, context: Self::Context<'ctx>, request: &mut Watch, output: &mut Self::Endpoints, ) -> Result<Response<InstanceState>>

fn stop(&mut self) -> impl Future<Output = Result<(), Self::Error>> + Send

fn cleanup(&mut self) -> impl Future<Output = Result<(), Self::Error>> + Send

fn transferred(&self) -> bool

fn classify(_error: &Self::Error) -> FailureKind