Skip to content
Permalink
Browse files

network-ntt: Catch up on BlockService changes

  • Loading branch information...
mzabaluev committed May 13, 2019
1 parent 6e90f43 commit 7c27bc4361abda5f6a205f778ce79b5eb69d5e6a
Showing with 10 additions and 1 deletion.
  1. +10 −1 network-ntt/src/client.rs
@@ -5,6 +5,7 @@ use chain_core::property::{Block, HasHeader, Header};
use network_core::{
client::{block::BlockService, P2pService},
error as core_error,
subscription::BlockEvent,
};
pub use protocol::protocol::ProtocolMagic;
use protocol::{
@@ -171,7 +172,8 @@ where
type PullBlocksToTipFuture = PullBlocksToTip<T>;
type GetBlocksStream = RequestStream<T>;
type GetBlocksFuture = RequestFuture<RequestStream<T>>;
type BlockSubscription = RequestStream<T::Header>;
type UploadBlocksFuture = RequestFuture<()>;
type BlockSubscription = RequestStream<BlockEvent<T>>;
type BlockSubscriptionFuture = RequestFuture<(Self::BlockSubscription, NodeId)>;

fn tip(&mut self) -> Self::TipFuture {
@@ -202,6 +204,13 @@ where
unimplemented!()
}

fn upload_blocks<S>(&mut self, _blocks: S) -> Self::UploadBlocksFuture
where
S: Stream<Item = Self::Block> + Send + 'static,
{
unimplemented!()
}

fn block_subscription<Out>(&mut self, _outbound: Out) -> Self::BlockSubscriptionFuture
where
Out: Stream<Item = T::Header>,

0 comments on commit 7c27bc4

Please sign in to comment.
You can’t perform that action at this time.