Added unpin impls to the futures
This commit is contained in:
		
							parent
							
								
									f92f46f489
								
							
						
					
					
						commit
						cdacc44c5f
					
				| @ -495,6 +495,8 @@ impl<'s, 'a, T: Clone> Future for SubscriberWaitFuture<'s, 'a, T> { | |||||||
|     } |     } | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
|  | impl<'s, 'a, T: Clone> Unpin for SubscriberWaitFuture<'s, 'a, T> {} | ||||||
|  | 
 | ||||||
| /// Future for the publisher wait action
 | /// Future for the publisher wait action
 | ||||||
| pub struct PublisherWaitFuture<'s, 'a, T: Clone> { | pub struct PublisherWaitFuture<'s, 'a, T: Clone> { | ||||||
|     /// The message we need to publish
 |     /// The message we need to publish
 | ||||||
| @ -526,6 +528,8 @@ impl<'s, 'a, T: Clone> Future for PublisherWaitFuture<'s, 'a, T> { | |||||||
|     } |     } | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
|  | impl<'s, 'a, T: Clone> Unpin for PublisherWaitFuture<'s, 'a, T> {} | ||||||
|  | 
 | ||||||
| /// The result of the subscriber wait procedure
 | /// The result of the subscriber wait procedure
 | ||||||
| #[derive(Debug, Clone, PartialEq)] | #[derive(Debug, Clone, PartialEq)] | ||||||
| pub enum WaitResult<T> { | pub enum WaitResult<T> { | ||||||
|  | |||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user