Function watch_command_state 

pub async fn watch_command_state(
    client: &mut KachakaApiClient<Channel>,
) -> impl Stream<Item = Result<CommandState, KachakaApiError>>