Struct StreamQueueSender 

pub(crate) struct StreamQueueSender {
    sender: Sender<UnparsedRelayMsg, MpscUnboundedSpec>,
    counter: Arc<Mutex<usize>>,
}

The sending end of a channel of incoming stream messages.

Fields

sender: Sender<UnparsedRelayMsg, MpscUnboundedSpec>

The inner sender.

counter: Arc<Mutex<usize>>

Number of bytes within the queue.

Implementations

impl StreamQueueSender

pub(crate) fn project<'pin>( self: Pin<&'pin mut Self>, ) -> __StreamQueueSenderProjection<'pin>

pub(crate) fn project_ref<'pin>( self: Pin<&'pin Self>, ) -> __StreamQueueSenderProjectionRef<'pin>

impl StreamQueueSender

pub(crate) fn approx_stream_bytes(&self) -> usize

Get the approximate number of data bytes queued for this stream.

As messages can be dequeued at any time, the return value may be larger than the actual number of bytes queued for this stream.

Trait Implementations

impl Debug for StreamQueueSender

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Sink<UnparsedRelayMsg> for StreamQueueSender

type Error = <Sender<UnparsedRelayMsg, MpscSpec> as Sink<UnparsedRelayMsg>>::Error

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut Self>, item: UnparsedRelayMsg, ) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.

impl SinkTrySend<UnparsedRelayMsg> for StreamQueueSender

type Error = <Sender<UnparsedRelayMsg, MpscSpec> as SinkTrySend<UnparsedRelayMsg>>::Error

Errors that is not disconnected, or full

fn try_send_or_return( self: Pin<&mut Self>, item: UnparsedRelayMsg, ) -> Result<(), (<Self as SinkTrySend<UnparsedRelayMsg>>::Error, UnparsedRelayMsg)>

Try to send a message msg

fn try_send(self: Pin<&mut Self>, item: T) -> Result<(), Self::Error>

Try to send a message msg

impl<'pin> Unpin for StreamQueueSender

where PinnedFieldsOf<__StreamQueueSender<'pin>>: Unpin,