pub fn send(
		mut self,
		notification: impl Into<Vec<u8>>
	) -> Result<(), ()> {
		self.lock.start_send(NotificationsSinkMessage::Notification {
			protocol_name: self.protocol_name,
			message: notification.into(),
		}).map_err(|_| ())
	}
/// Consumes this slots reservation and actually queues the notification.
///
/// Returns an error if the substream has been closed.
Consumes this slots reservation and actually queues the notification.
Returns an error if the substream has been closed.
Consumes this slots reservation and actually queues the notification . Returns an error if the substream has been closed .
pub fn send(
		mut self,
		notification: impl Into<Vec<u8>>
	) -> Result<(), ()> {
		self.lock.start_send(NotificationsSinkMessage::Notification {
			protocol_name: self.protocol_name,
			message: notification.into(),
		}).map_err(|_| ())
	}
pub fn send ( mut self , notification : impl Into < Vec < u8 > > ) -> Result < ( ) , ( ) > { self . lock . start_send ( NotificationsSinkMessage :: Notification { protocol_name : self . protocol_name , message : notification . into ( ) , } ) . map_err ( | _ | ( ) ) }
Consumes this slots reservation and actually queues the notification.
Consumes this slots reservation and actually queues the notification .
mut self
notification
impl Into<Vec<u8>>
mut self
notification
impl Into<Vec<u8>>