diff options
author | Felix Lange <fjl@twurst.com> | 2017-01-06 22:52:03 +0800 |
---|---|---|
committer | Felix Lange <fjl@twurst.com> | 2017-01-06 22:52:03 +0800 |
commit | 35a7dcb162546f7f31cb6492f716cb93159218d7 (patch) | |
tree | 4828026948031719a703a87e0ce909e82da21d3b /rpc | |
parent | e0fde022909d272e55fb9ea2d4f8cfe9f178dba8 (diff) | |
download | go-tangerine-35a7dcb162546f7f31cb6492f716cb93159218d7.tar go-tangerine-35a7dcb162546f7f31cb6492f716cb93159218d7.tar.gz go-tangerine-35a7dcb162546f7f31cb6492f716cb93159218d7.tar.bz2 go-tangerine-35a7dcb162546f7f31cb6492f716cb93159218d7.tar.lz go-tangerine-35a7dcb162546f7f31cb6492f716cb93159218d7.tar.xz go-tangerine-35a7dcb162546f7f31cb6492f716cb93159218d7.tar.zst go-tangerine-35a7dcb162546f7f31cb6492f716cb93159218d7.zip |
all: gofmt -w -s
Diffstat (limited to 'rpc')
-rw-r--r-- | rpc/json.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/rpc/json.go b/rpc/json.go index ac5a4acd3..61a4ddf43 100644 --- a/rpc/json.go +++ b/rpc/json.go @@ -166,7 +166,7 @@ func parseRequest(incomingMsg json.RawMessage) ([]rpcRequest, bool, Error) { // subscribe are special, they will always use `subscribeMethod` as first param in the payload if in.Method == subscribeMethod { - reqs := []rpcRequest{rpcRequest{id: &in.Id, isPubSub: true}} + reqs := []rpcRequest{{id: &in.Id, isPubSub: true}} if len(in.Payload) > 0 { // first param must be subscription name var subscribeMethod [1]string @@ -184,7 +184,7 @@ func parseRequest(incomingMsg json.RawMessage) ([]rpcRequest, bool, Error) { } if in.Method == unsubscribeMethod { - return []rpcRequest{rpcRequest{id: &in.Id, isPubSub: true, + return []rpcRequest{{id: &in.Id, isPubSub: true, method: unsubscribeMethod, params: in.Payload}}, false, nil } @@ -195,10 +195,10 @@ func parseRequest(incomingMsg json.RawMessage) ([]rpcRequest, bool, Error) { // regular RPC call if len(in.Payload) == 0 { - return []rpcRequest{rpcRequest{service: elems[0], method: elems[1], id: &in.Id}}, false, nil + return []rpcRequest{{service: elems[0], method: elems[1], id: &in.Id}}, false, nil } - return []rpcRequest{rpcRequest{service: elems[0], method: elems[1], id: &in.Id, params: in.Payload}}, false, nil + return []rpcRequest{{service: elems[0], method: elems[1], id: &in.Id, params: in.Payload}}, false, nil } // parseBatchRequest will parse a batch request into a collection of requests from the given RawMessage, an indication |