fix: add send + unpin to stream type (#402)
This commit is contained in:
parent
26324343ec
commit
e6cd74cf1f
|
@ -15,7 +15,7 @@ use std::{
|
||||||
/// A transport implementation supporting pub sub subscriptions.
|
/// A transport implementation supporting pub sub subscriptions.
|
||||||
pub trait PubsubClient: JsonRpcClient {
|
pub trait PubsubClient: JsonRpcClient {
|
||||||
/// The type of stream this transport returns
|
/// The type of stream this transport returns
|
||||||
type NotificationStream: futures_core::Stream<Item = Value>;
|
type NotificationStream: futures_core::Stream<Item = Value> + Send + Unpin;
|
||||||
|
|
||||||
/// Add a subscription to this transport
|
/// Add a subscription to this transport
|
||||||
fn subscribe<T: Into<U256>>(&self, id: T) -> Result<Self::NotificationStream, Self::Error>;
|
fn subscribe<T: Into<U256>>(&self, id: T) -> Result<Self::NotificationStream, Self::Error>;
|
||||||
|
|
Loading…
Reference in New Issue