1 files changed, 36 insertions, 0 deletions
diff --git a/third_party/rust/audioipc/src/rpc/mod.rs b/third_party/rust/audioipc/src/rpc/mod.rs
new file mode 100644
index 0000000000..8d54fc6e00
--- /dev/null
+++ b/third_party/rust/audioipc/src/rpc/mod.rs
@@ -0,0 +1,36 @@
+// Copyright © 2017 Mozilla Foundation
+//
+// This program is made available under an ISC-style license.  See the
+// accompanying file LICENSE for details
+
+use futures::{Poll, Sink, Stream};
+use std::io;
+
+mod client;
+mod driver;
+mod server;
+
+pub use self::client::{bind_client, Client, ClientProxy, Response};
+pub use self::server::{bind_server, Server};
+
+pub trait Handler {
+    /// Message type read from transport
+    type In;
+    /// Message type written to transport
+    type Out;
+    type Transport: 'static
+        + Stream<Item = Self::In, Error = io::Error>
+        + Sink<SinkItem = Self::Out, SinkError = io::Error>;
+
+    /// Mutable reference to the transport
+    fn transport(&mut self) -> &mut Self::Transport;
+
+    /// Consume a request
+    fn consume(&mut self, message: Self::In) -> io::Result<()>;
+
+    /// Produce a response
+    fn produce(&mut self) -> Poll<Option<Self::Out>, io::Error>;
+
+    /// RPC currently in flight
+    fn has_in_flight(&self) -> bool;
+}