Skip to content

Commit 83f989c

Browse files
committed
fix(volo-grpc): don't need sync for BoxStream and encode
1 parent eecfc6e commit 83f989c

File tree

4 files changed

+4
-5
lines changed

4 files changed

+4
-5
lines changed

Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

volo-grpc/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[package]
22
name = "volo-grpc"
3-
version = "0.11.6"
3+
version = "0.11.7"
44
edition.workspace = true
55
homepage.workspace = true
66
repository.workspace = true

volo-grpc/src/codec/encode.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ pub fn encode<T, S>(
1717
compression_encoding: Option<CompressionEncoding>,
1818
) -> BoxStream<'static, Result<Frame<Bytes>, Status>>
1919
where
20-
S: Stream<Item = Result<T, Status>> + Send + Sync + 'static,
20+
S: Stream<Item = Result<T, Status>> + Send + 'static,
2121
T: Message + 'static,
2222
{
2323
Box::pin(async_stream::stream! {

volo-grpc/src/lib.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,9 @@ pub mod tracing;
2222
pub mod transport;
2323

2424
pub type BoxError = Box<dyn std::error::Error + Send + Sync>;
25-
pub type BoxStream<'l, T> = std::pin::Pin<Box<dyn futures::Stream<Item = T> + Send + Sync + 'l>>;
26-
2725
pub use client::Client;
2826
pub use codec::decode::RecvStream;
27+
pub use futures::stream::BoxStream;
2928
pub use message::{RecvEntryMessage, SendEntryMessage};
3029
pub use request::{IntoRequest, IntoStreamingRequest, Request};
3130
pub use response::Response;

0 commit comments

Comments
 (0)