Lines Matching refs:unfold
658 let unfold = sink::unfold((), |(), i: i32| { in sink_unfold() localVariable
665 futures::pin_mut!(unfold); in sink_unfold()
666 assert_eq!(unfold.as_mut().start_send(1), Ok(())); in sink_unfold()
667 assert_eq!(unfold.as_mut().poll_flush(cx), Poll::Ready(Ok(()))); in sink_unfold()
670 assert_eq!(unfold.as_mut().poll_ready(cx), Poll::Ready(Ok(()))); in sink_unfold()
671 assert_eq!(unfold.as_mut().start_send(2), Ok(())); in sink_unfold()
672 assert_eq!(unfold.as_mut().poll_ready(cx), Poll::Ready(Ok(()))); in sink_unfold()
673 assert_eq!(unfold.as_mut().start_send(3), Ok(())); in sink_unfold()
676 assert_eq!(unfold.as_mut().poll_ready(cx), Poll::Ready(Ok(()))); in sink_unfold()
677 assert_eq!(unfold.as_mut().start_send(4), Ok(())); in sink_unfold()
678 assert_eq!(unfold.as_mut().poll_flush(cx), Poll::Pending); // Channel full in sink_unfold()