From 9075b967d12e79e4b276f96d227fd55f1817a5c7 Mon Sep 17 00:00:00 2001
From: coffeepots <coffeepotsgh@gmail.com>
Date: Mon, 9 Jul 2018 09:58:39 +0100
Subject: [PATCH] Move start, stop and close to transport specific
 sockettransport

---
 json_rpc/server.nim          | 15 ---------------
 json_rpc/sockettransport.nim | 14 ++++++++++++++
 2 files changed, 14 insertions(+), 15 deletions(-)

diff --git a/json_rpc/server.nim b/json_rpc/server.nim
index a564957..98d8b12 100644
--- a/json_rpc/server.nim
+++ b/json_rpc/server.nim
@@ -134,21 +134,6 @@ proc processMessages*[T](server: RpcServer[T], line: string): Future[string] {.a
         error = wrapError(METHOD_NOT_FOUND, "Method not found", id, methodNotFound)
       result = $wrapReply(id, newJNull(), error)
 
-proc start*(server: RpcServer) =
-  ## Start the RPC server.
-  for item in server.servers:
-    item.start()
-
-proc stop*(server: RpcServer) =
-  ## Stop the RPC server.
-  for item in server.servers:
-    item.stop()
-
-proc close*(server: RpcServer) =
-  ## Cleanup resources of RPC server.
-  for item in server.servers:
-    item.close()
-
 # Server registration
 
 proc register*(server: RpcServer, name: string, rpc: RpcProc) =
diff --git a/json_rpc/sockettransport.nim b/json_rpc/sockettransport.nim
index 9409eb4..54c6be2 100644
--- a/json_rpc/sockettransport.nim
+++ b/json_rpc/sockettransport.nim
@@ -140,3 +140,17 @@ proc newRpcStreamServer*(address = "localhost", port: Port = Port(8545)): RpcStr
   result = newRpcServer[StreamServer]()
   result.addStreamServer(address, port)
 
+proc start*(server: RpcStreamServer) =
+  ## Start the RPC server.
+  for item in server.servers:
+    item.start()
+
+proc stop*(server: RpcStreamServer) =
+  ## Stop the RPC server.
+  for item in server.servers:
+    item.stop()
+
+proc close*(server: RpcStreamServer) =
+  ## Cleanup resources of RPC server.
+  for item in server.servers:
+    item.close()
\ No newline at end of file