Removed sender field.
This commit is contained in:
		
							
								
								
									
										28
									
								
								src/field.rs
									
									
									
									
									
								
							
							
						
						
									
										28
									
								
								src/field.rs
									
									
									
									
									
								
							@@ -44,12 +44,6 @@ impl From<Uuid> for Field {
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
impl From<Sender<Message>> for Field {
 | 
			
		||||
    fn from(value: Sender<Message>) -> Self {
 | 
			
		||||
        Field::Tx(value)
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
impl fmt::Display for Field {
 | 
			
		||||
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
 | 
			
		||||
        match self {
 | 
			
		||||
@@ -117,19 +111,6 @@ mod fields {
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    #[test]
 | 
			
		||||
    fn sender_to_field() {
 | 
			
		||||
        let (tx, rx) = channel::<Message>();
 | 
			
		||||
        match tx.into() {
 | 
			
		||||
            Field::Tx(sender) => {
 | 
			
		||||
                let msg = Message::new();
 | 
			
		||||
                sender.send(msg).unwrap();
 | 
			
		||||
                rx.recv().unwrap();
 | 
			
		||||
            }
 | 
			
		||||
            _ => unreachable!("should have been a sender"),
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    #[test]
 | 
			
		||||
    fn uuid_field_to_string() {
 | 
			
		||||
        let id = Uuid::new_v4();
 | 
			
		||||
@@ -151,13 +132,4 @@ mod fields {
 | 
			
		||||
        let input: Field = result.clone().into();
 | 
			
		||||
        assert_eq!(input.to_string(), result);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    #[test]
 | 
			
		||||
    fn get_sender() {
 | 
			
		||||
        let (tx, rx) = channel::<Message>();
 | 
			
		||||
        let field: Field = tx.into();
 | 
			
		||||
        let sender = field.to_sender().unwrap();
 | 
			
		||||
        sender.send(Message::new()).unwrap();
 | 
			
		||||
        rx.recv().unwrap();
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user