Safe Haskell	Safe-Inferred
Language	Haskell2010

Ouroboros.Network.Protocol.BlockFetch.Server

Synopsis

data BlockFetchServer block point m a where
- BlockFetchServer :: ( ChainRange point -> m ( BlockFetchBlockSender block point m a)) -> a -> BlockFetchServer block point m a
data BlockFetchBlockSender block point m a where
- SendMsgStartBatch :: m ( BlockFetchSendBlocks block point m a) -> BlockFetchBlockSender block point m a
- SendMsgNoBlocks :: m ( BlockFetchServer block point m a) -> BlockFetchBlockSender block point m a
data BlockFetchSendBlocks block point m a where
- SendMsgBlock :: block -> m ( BlockFetchSendBlocks block point m a) -> BlockFetchSendBlocks block point m a
- SendMsgBatchDone :: m ( BlockFetchServer block point m a) -> BlockFetchSendBlocks block point m a
blockFetchServerPeer :: forall block point m a. Functor m => BlockFetchServer block point m a -> Peer ( BlockFetch block point) AsServer BFIdle m a

Documentation

data BlockFetchServer block point m a where Source #

Constructors

data BlockFetchBlockSender block point m a where Source #

Send batches of blocks, when a batch is sent loop using BlockFetchServer .

Constructors

SendMsgStartBatch :: m ( BlockFetchSendBlocks block point m a) -> BlockFetchBlockSender block point m a	Initiate a batch of blocks.
SendMsgNoBlocks :: m ( BlockFetchServer block point m a) -> BlockFetchBlockSender block point m a

data BlockFetchSendBlocks block point m a where Source #

Stream batch of blocks

Constructors

SendMsgBlock :: block -> m ( BlockFetchSendBlocks block point m a) -> BlockFetchSendBlocks block point m a	Send a single block and recurse.
SendMsgBatchDone :: m ( BlockFetchServer block point m a) -> BlockFetchSendBlocks block point m a	End of the stream of block bodies.