aboutsummaryrefslogtreecommitdiff
path: root/rust/src/implementation/passwordmaker/emittingsender.rs
diff options
context:
space:
mode:
Diffstat (limited to 'rust/src/implementation/passwordmaker/emittingsender.rs')
-rw-r--r--rust/src/implementation/passwordmaker/emittingsender.rs17
1 files changed, 17 insertions, 0 deletions
diff --git a/rust/src/implementation/passwordmaker/emittingsender.rs b/rust/src/implementation/passwordmaker/emittingsender.rs
new file mode 100644
index 0000000..1cf58fc
--- /dev/null
+++ b/rust/src/implementation/passwordmaker/emittingsender.rs
@@ -0,0 +1,17 @@
+use std::sync::mpsc::{channel,Sender,Receiver,SendError};
+#[derive(Clone)]
+pub(crate) struct EmittingSender<MT, E : Fn()> {
+ sender : Sender<MT>,
+ emit : E,
+}
+
+impl <MT, E : Fn()> EmittingSender<MT, E>{
+ pub(crate) fn emitting_channel(emit : E) -> (Self, Receiver<MT>) {
+ let (sender,r) = channel();
+ (EmittingSender { sender, emit }, r)
+ }
+ pub(crate) fn send(&self, t: MT) -> Result<(), SendError<MT>> {
+ //first send, then notify.
+ self.sender.send(t).map(|_| (self.emit)())
+ }
+}