Initial commit - extracted urpc from monorepo

1 files changed, 52 insertions, 0 deletions

diff --git a/src/lib.rs b/src/lib.rs
new file mode 100644
index 0000000..e65f659
--- /dev/null
+++ b/src/lib.rs
@@ -0,0 +1,52 @@
+#[doc(hidden)]
+pub mod internal;
+
+pub mod channel;
+pub mod protocol;
+pub mod tcp;
+pub mod unix;
+
+mod client_channel;
+mod server;
+
+pub use client_channel::ClientChannel;
+pub use server::Server;
+pub use urpc_macro::service;
+
+use protocol::RpcMessage;
+
+use std::pin::Pin;
+use std::future::Future;
+
+use bytes::Bytes;
+use futures::{Sink, Stream};
+
+#[derive(Debug, Default)]
+pub struct Context;
+
+pub trait Service: Send + Sync + 'static {
+    fn name() -> &'static str
+    where
+        Self: Sized;
+
+    fn call(
+        &self,
+        method: String,
+        arguments: Bytes,
+    ) -> Pin<Box<dyn Future<Output = std::io::Result<Bytes>> + Send + '_>>;
+}
+
+pub trait Channel:
+    Stream<Item = std::io::Result<RpcMessage>>
+    + Sink<RpcMessage, Error = std::io::Error>
+    + Send
+    + Unpin
+    + 'static
+{
+}
+
+pub trait Listener<C>: Stream<Item = std::io::Result<C>> + Send + Unpin + 'static
+where
+    C: Channel,
+{
+}