File tree 1 file changed +2
-0
lines changed
1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -624,6 +624,7 @@ impl<T> BoundedSenderInner<T> {
624
624
///
625
625
/// - `Poll::Ready(()` if there are no messages in the channel;
626
626
/// - `Poll::Pending` if there are messages in the channel.
627
+ #[ cfg( feature = "sink" ) ]
627
628
fn poll_is_empty ( & mut self , cx : & mut Context < ' _ > ) -> Poll < ( ) > {
628
629
let state = decode_state ( self . inner . state . load ( SeqCst ) ) ;
629
630
if state. num_messages == 0 {
@@ -783,6 +784,7 @@ impl<T> Sender<T> {
783
784
///
784
785
/// - `Poll::Ready(()` if there are no messages in the channel or the [`Receiver`] is disconnected.
785
786
/// - `Poll::Pending` if there are messages in the channel.
787
+ #[ cfg( feature = "sink" ) ]
786
788
pub ( crate ) fn poll_is_empty ( & mut self , cx : & mut Context < ' _ > ) -> Poll < ( ) > {
787
789
let inner = match self . 0 . as_mut ( ) {
788
790
None => return Poll :: Ready ( ( ) ) ,
You can’t perform that action at this time.
0 commit comments