diff --git a/queue/rpc.go b/queue/rpc.go index 321d45d..ea8ffb4 100644 --- a/queue/rpc.go +++ b/queue/rpc.go @@ -2,19 +2,24 @@ package queue import "errors" +// RPCReq contains information for communicating with the RPC server type RPCReq struct { method string replyChan chan interface{} } +// RPCResponse holds the response type RPCResponse string +// Status contains RPC request information type Status struct { queueChan chan RPCReq } +// RPCArgs arg information for the RPC server type RPCArgs struct{} +// Downloads gets download statuses func (s *Status) Downloads(_ RPCArgs, reply *RPCResponse) error { replyChan := make(chan interface{}) req := RPCReq{ @@ -31,7 +36,6 @@ func (s *Status) Downloads(_ RPCArgs, reply *RPCResponse) error { break default: return errors.New("error: unexpected return value") - break } return nil