Commits

Yaron Minsky  committed 59a4baf

added .merlin file

  • Participants
  • Parent commits 9033369

Comments (0)

Files changed (5)

+S .
+B _dir
+PKG async core core_extended

File build_all.sh

 
 EXT=byte
 
-corebuild \
+corebuild -j 3  \
     hello_world.$EXT \
     hello_client.$EXT \
     hello_server.$EXT \

File directory.ml

 module Topic_pub : sig
   type t
   val create : Message.t -> t
-  val publish : t -> Message.t -> unit
-  val subscribe : t -> Message.t Pipe.Reader.t
+
+  val publish         : t -> Message.t -> unit
+  val subscribe       : t -> Message.t Pipe.Reader.t
   val num_subscribers : t -> int
-  val last_message : t -> Message.t
-  val clear : t -> unit
+  val last_message    : t -> Message.t
+  val clear           : t -> unit
 end = struct
   type t = { mutable last_message: Message.t;
              mutable subscribers: Message.t Pipe.Writer.t list;
     let num_subscribers = Topic_pub.num_subscribers tpub in
     let message = Topic_pub.last_message tpub in
     {Dump. num_subscribers; message })
+

File hello_client.ml

 open Async.Std
 
 (* A command that sends the hello request  *)
-let say_hello =
+let say_hello ~host ~port =
   Common.with_rpc_conn (fun conn ->
     Rpc.Rpc.dispatch_exn Hello_protocol.hello_rpc conn "Hello"
     >>| fun response ->
     printf "%s\n%!" response
   )
+    ~host ~port
 
 let command =
   Command.async_basic

File hello_server.ml

 let hello_impl () hello =
   Log.Global.debug "received hello query (%s)" hello;
   Clock.after (sec 0.1)
-  >>= fun () -> return (hello ^ " World!")
+  >>= fun () ->
+(*  return (String.length hello) *)
+  return (hello ^ " World!")
 
 (* The list of RPC implementations supported by this server *)
 let implementations =