Improving the external API.

core/src/io.rs

@@ -192,7 +192,8 @@ impl<T: Metadata, S: Middleware<T>> MetaIoHandler<T, S> {
 		}).boxed()
 	}
 
-	fn handle_call(&self, call: Call, meta: T) -> BoxFuture<Option<Output>, ()> {
+	/// Handle single call asynchronously.
+	pub fn handle_call(&self, call: Call, meta: T) -> BoxFuture<Option<Output>, ()> {
 		match call {
 			Call::MethodCall(method) => {
 				let params = method.params.unwrap_or(Params::None);

core/src/types/request.rs

@@ -47,6 +47,18 @@ pub enum Call {
 
 }
 
+impl From<MethodCall> for Call {
+	fn from(mc: MethodCall) -> Self {
+		Call::MethodCall(mc)
+	}
+}
+
+impl From<Notification> for Call {
+	fn from(n: Notification) -> Self {
+		Call::Notification(n)
+	}
+}
+
 impl Serialize for Call {
 	fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
 	where S: Serializer {

macros/src/auto_args.rs

@@ -233,6 +233,7 @@ macro_rules! build_rpc_trait {
 				)
 			}),
 			($unsubscribe, move |base, id| {
+				use $crate::jsonrpc_core::futures::Future;
 				Self::$unsub_method(base, id).map($crate::to_value).boxed()
 			}),
 		);

macros/src/lib.rs

@@ -1,4 +1,4 @@
-extern crate jsonrpc_core;
+pub extern crate jsonrpc_core;
 extern crate jsonrpc_pubsub;
 extern crate serde;
 

macros/src/pubsub.rs

@@ -25,8 +25,9 @@ impl<T> Subscriber<T> {
 	}
 
 	pub fn assign_id(self, id: SubscriptionId) -> Result<Sink<T>, ()> {
-		let sink = self.subscriber.assign_id(id)?;
+		let sink = self.subscriber.assign_id(id.clone())?;
 		Ok(Sink {
+			id: id,
 			sink: sink,
 			_data: PhantomData,
 		})
@@ -35,12 +36,17 @@ impl<T> Subscriber<T> {
 
 pub struct Sink<T> {
 	sink: pubsub::Sink,
+	id: SubscriptionId,
 	_data: PhantomData<T>,
 }
 
 impl<T: serde::Serialize> Sink<T> {
 	pub fn send(&self, val: T) -> pubsub::SinkResult {
+		let id = self.id.clone().into();
 		let val = to_value(val);
-		self.sink.send(core::Params::Array(vec![val]))
+		self.sink.send(core::Params::Map(vec![
+			("subscription".to_owned(), id),
+			("result".to_owned(), val),
+		].into_iter().collect()))
 	}
 }

pubsub/src/subscription.rs

@@ -1,5 +1,6 @@
 //! Subscription primitives.
 
+use std::fmt;
 use std::collections::HashMap;
 use std::sync::Arc;
 use parking_lot::Mutex;
@@ -19,6 +20,15 @@ pub struct Session {
 	on_drop: Mutex<Vec<Box<Fn() + Send>>>,
 }
 
+impl fmt::Debug for Session {
+	fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
+		fmt.debug_struct("pubsub::Session")
+			.field("active_subscriptions", &self.active_subscriptions.lock().len())
+			.field("transport", &self.transport)
+			.finish()
+	}
+}
+
 impl Session {
 	/// Creates new session given transport raw send capabilities.
 	/// Session should be created as part of metadata, `sender` should be returned by transport.