pub async fn next_wft(&self) -> Option<pollers::Result<PollWorkflowTaskQueueResponse>> {
        if let Some(wft) = self.from_completions.pop() {
            self.task_taken_notifier.notify_one();
            return Some(Ok(wft));
        }
        self.poll_buffer.poll().await
    }
/// Returns the next available WFT if one is already stored from a completion, otherwise
/// forwards to the poller.
Returns the next available WFT if one is already stored from a completion, otherwise
forwards to the poller.
Returns the next available WFT if one is already stored from a completion otherwise forwards to the poller .
pub async fn next_wft(&self) -> Option<pollers::Result<PollWorkflowTaskQueueResponse>> {
        if let Some(wft) = self.from_completions.pop() {
            self.task_taken_notifier.notify_one();
            return Some(Ok(wft));
        }
        self.poll_buffer.poll().await
    }
pub async fn next_wft ( & self ) -> Option < pollers :: Result < PollWorkflowTaskQueueResponse > > { if let Some ( wft ) = self . from_completions . pop ( ) { self . task_taken_notifier . notify_one ( ) ; return Some ( Ok ( wft ) ) ; } self . poll_buffer . poll ( ) . await }
Returns the next available WFT if one is already stored from a completion, otherwise
forwards to the poller.
Returns the next available WFT if one is already stored from a completion otherwise forwards to the poller .
&self
&self