Feature/async spf

samotop-delivery/src/journal/stream.rs

@@ -196,9 +196,10 @@ impl io::Write for JournalStream {
     }
 }
 
+type BucketTuple = (Arc<Potential<Bucket>>, Option<(Uuid, usize)>);
 enum State {
     Ready(Arc<Potential<Bucket>>),
-    Encoding(S3Fut<Result<(Arc<Potential<Bucket>>, Option<(Uuid, usize)>), Error>>),
+    Encoding(S3Fut<Result<BucketTuple, Error>>),
     Closing(S3Fut<Result<(), Error>>),
     Invalid,
 }