round-based 0.4.1

Driver for MPC protocols
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use core::convert::Infallible;

use phantom_type::PhantomType;

use crate::{Delivery, Incoming, Outgoing};

pub fn fake_delivery<M>() -> impl Delivery<M> {
    struct FakeDelivery<M>(PhantomType<M>);
    impl<M> Delivery<M> for FakeDelivery<M> {
        type Send = futures_util::sink::Drain<Outgoing<M>>;
        type Receive = futures_util::stream::Pending<Result<Incoming<M>, Infallible>>;

        type SendError = Infallible;
        type ReceiveError = Infallible;

        fn split(self) -> (Self::Receive, Self::Send) {
            (futures_util::stream::pending(), futures_util::sink::drain())
        }
    }
    FakeDelivery(PhantomType::new())
}