Struct DownloadStream 

pub struct DownloadStream {
    inner: Streaming<DownloadStreamResponse>,
}

Wrapper for an asynchronous download stream.

This type wraps the tonic streaming API to provide a convenient interface for iterating over download chunks.

Example

use Mountain::Air::AirClient::DownloadStream;
use CommonLibrary::Error::CommonError::CommonError;

# #[tokio::main]
# async fn main() -> Result<(), CommonError> {
# let mut stream = DownloadStream::new(/* tonic stream */);
let mut buffer = Vec::new();
while let Some(chunk) = stream.next().await {
	let chunk = chunk?;
	buffer.extend_from_slice(&chunk.data);
	if chunk.completed {
		break;
	}
}
# Ok(())
# }

Fields

inner: Streaming<DownloadStreamResponse>

Implementations

impl DownloadStream

pub fn new(stream: Streaming<DownloadStreamResponse>) -> Self

Creates a new DownloadStream from a tonic streaming response.

pub async fn next(&mut self) -> Option<Result<DownloadStreamChunk, CommonError>>

Returns the next chunk from the stream.

Returns None when the stream ends.