1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38
use async_std::sync::{ Sender }; use crate::base as base; use base::{ RecApp, Protocol }; pub struct ReceiveValue < T, P > ( pub (crate) Sender < ( T, Sender < P > ) > ); impl < T, P > Protocol for ReceiveValue < T, P > where T : Send + 'static, P : Protocol { } impl < A, T, P > RecApp < A > for ReceiveValue < T, P > where A : Send + 'static, T : Send + 'static, P : RecApp < A >, { type Applied = ReceiveValue < T, P :: Applied >; }