Lines Matching refs:poll_unpin

341             assert!(task.poll_unpin(cx).is_pending());  in mpsc_blocking_start_send()
345             unwrap(task.poll_unpin(cx));  in mpsc_blocking_start_send()
379         assert!(task.poll_unpin(cx).is_pending());  in with_flush()
383         unwrap(task.poll_unpin(cx));  in with_flush()
477             assert!(task.poll_unpin(cx).is_pending());  in with_flush_propagate()
482         unwrap(sink.flush().poll_unpin(cx));  in with_flush_propagate()
559         assert!(task.poll_unpin(cx).is_pending());  in buffer()
563         unwrap(task.poll_unpin(cx));  in buffer()
604         assert!(task.poll_unpin(cx).is_pending());  in fanout_backpressure()
607         assert!(task.poll_unpin(cx).is_pending());  in fanout_backpressure()
611         assert!(task.poll_unpin(cx).is_pending());  in fanout_backpressure()
614         assert!(task.poll_unpin(cx).is_pending());  in fanout_backpressure()
618         unwrap(task.poll_unpin(cx));  in fanout_backpressure()