Dmitry Galinsky dmexe

## next_ok_or_last_err.rs
/// It converts an inner stream into a future, which
/// pick up a first ok result from the stream and stop
/// or if a stream ended without any successful result return
/// a last recorded error from the stream.
///
/// Usage:
/// ```
/// let stream = iter_ok(vec![1,2,3]);
/// let future = stream.next_ok_or_last_err();
/// ```

## events.log.md

      
        
          
            
              
              1 file
            
          
          
            
              
              0 forks
            
          
          
            
              
              0 comments
            
          
          
            
              
              0 stars
            
          
        
        
          
              
          
          
            
                dmexe
                / events.log.md
            
            
              Last active
              May 22, 2021 15:28
            
          
        
      
        
  
      
    Publisher

When published an import to audio2 for processing
{
  "message": "Successfully published ImportCreatedOrUpdated(123e4567-e89b-12d3-a456-426614174000) to publisher-v1-json-events[2]/14788",
  "event.kind": "event",
  "event.created": "2016-05-23T08:05:34.853Z",
  "event.code": "publisher:import_created_or_updated",
	/// It converts an inner stream into a future, which
	/// pick up a first ok result from the stream and stop
	/// or if a stream ended without any successful result return
	/// a last recorded error from the stream.
	///
	/// Usage:
	/// ```
	/// let stream = iter_ok(vec![1,2,3]);
	/// let future = stream.next_ok_or_last_err();
	/// ```