summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorYorhel <git@yorhel.nl>2012-01-24 18:23:32 +0100
committerYorhel <git@yorhel.nl>2012-01-24 18:23:32 +0100
commit20937e8882248fc85d55447521c631916aa0e092 (patch)
treeab86b8a9d11662802163ef9cd854f9e3daf9c2ba
parent6d61ea25b97404cd4a797e104d79b98dad3afe88 (diff)
tcomm: Removed SendT() and RequestT()
I realized you can just use "..." to expand a slice to vararg functions.
-rw-r--r--tcomm/server.go12
-rw-r--r--tcomm/session.go4
2 files changed, 4 insertions, 12 deletions
diff --git a/tcomm/server.go b/tcomm/server.go
index e7f7729..d2e9886 100644
--- a/tcomm/server.go
+++ b/tcomm/server.go
@@ -17,20 +17,12 @@ func ServerCreate() *Server {
}
func (s *Server) Send(t ...interface{}) {
- s.SendT(Tuple(t))
-}
-
-func (s *Server) SendT(t Tuple) {
- s.snd <- &serverSend{t, nil}
+ s.snd <- &serverSend{Tuple(t), nil}
}
func (s *Server) Request(t ...interface{}) <-chan Tuple {
- return s.RequestT(Tuple(t))
-}
-
-func (s *Server) RequestT(t Tuple) <-chan Tuple {
ch := make(chan Tuple, 100) // TODO: make sure this is buffered
- s.snd <- &serverSend{t, ch}
+ s.snd <- &serverSend{Tuple(t), ch}
return ch
}
diff --git a/tcomm/session.go b/tcomm/session.go
index 2ba101b..ad7e239 100644
--- a/tcomm/session.go
+++ b/tcomm/session.go
@@ -89,11 +89,11 @@ func (serv *Server) Session() *Session {
}
func (s *Session) Send(t ...interface{}) {
- s.serv.SendT(Tuple(t))
+ s.serv.Send(t...)
}
func (s *Session) Request(t ...interface{}) <-chan Tuple {
- return s.serv.RequestT(Tuple(t))
+ return s.serv.Request(t...)
}
func (s *Session) registerRaw(willReply bool, f interface{}, p Pattern) SessionReg {