channel.rs 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. /// Creates an implentation of sender which can be used to share an async channel for multiple message types.
  2. ///
  3. /// # Examples
  4. ///
  5. /// ```
  6. /// struct D;
  7. /// struct A;
  8. ///
  9. /// enum Msg {
  10. /// FirstType(D),
  11. /// SecondType(A)
  12. /// }
  13. ///
  14. /// fn main() {
  15. /// let (tx, rx) = channel::<Msg>();
  16. ///
  17. /// let d_sender = DSender::create(tx.clone());
  18. /// let a_sender = ASender::create(tx.clone());
  19. /// subscribe(d_sender.clone());
  20. /// subscribe2(d_sender.clone());
  21. /// subscribe3(a_sender.clone());
  22. //
  23. /// let mut i = 0;
  24. //
  25. /// for m in rx {
  26. /// i += 1;
  27. /// match m {
  28. /// Msg::FirstType(_) => println!("m: D {}", i),
  29. /// Msg::SecondType(_) => println!("m: A {}", i)
  30. /// };
  31. /// }
  32. /// }
  33. ///
  34. /// fn subscribe(sender: DSender) {
  35. /// thread::spawn(move|| {
  36. /// sender.send(D).unwrap();
  37. /// });
  38. /// }
  39. /// fn subscribe2(sender: DSender) {
  40. /// thread::spawn(move|| {
  41. /// thread::sleep(time::Duration::from_millis(10));
  42. /// sender.send(D).unwrap();
  43. /// });
  44. /// }
  45. /// fn subscribe3(sender: ASender) {
  46. /// thread::spawn(move|| {
  47. /// sender.send(A).unwrap();
  48. /// });
  49. /// }
  50. /// implement_sender!(name => DSender,
  51. /// wrap => D,
  52. /// with => Msg,
  53. /// variant => FirstType)
  54. /// implement_sender!(name => ASender,
  55. /// wrap => A,
  56. /// with => Msg,
  57. /// variant => SecondType)
  58. /// ```
  59. macro_rules! implement_sender {
  60. (name => $name:ident,
  61. wrap => $wrap_type:ident,
  62. with => $with_type:ident,
  63. variant => $variant:ident) => {
  64. pub struct $name {
  65. wrapped_sender: ::std::sync::mpsc::Sender<$with_type>,
  66. }
  67. impl $name {
  68. pub fn create(sender: ::std::sync::mpsc::Sender<$with_type>) -> $name {
  69. $name {
  70. wrapped_sender: sender
  71. }
  72. }
  73. pub fn send(&self, t: $wrap_type) -> Result<(), ::std::sync::mpsc::SendError<$wrap_type>> {
  74. let wrapped = self.wrap(t);
  75. let result = self.wrapped_sender.send(wrapped);
  76. result.map_err(|senderror| {
  77. let ::std::sync::mpsc::SendError(z) = senderror;
  78. ::std::sync::mpsc::SendError(self.unwrap(z))
  79. })
  80. }
  81. fn wrap(&self, d: $wrap_type) -> $with_type {
  82. $with_type::$variant(d)
  83. }
  84. fn unwrap(&self, msg: $with_type) -> $wrap_type {
  85. let d = match msg {
  86. $with_type::$variant(d) => d,
  87. _ => unreachable!()
  88. };
  89. d
  90. }
  91. }
  92. impl Clone for $name {
  93. fn clone(&self) -> $name {
  94. $name {
  95. wrapped_sender: self.wrapped_sender.clone()
  96. }
  97. }
  98. }
  99. }
  100. }