Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewServerCodec (0.2 sec)

  1. src/net/rpc/jsonrpc/server.go

    	// the response to find the original request ID.
    	mutex   sync.Mutex // protects seq, pending
    	seq     uint64
    	pending map[uint64]*json.RawMessage
    }
    
    // NewServerCodec returns a new [rpc.ServerCodec] using JSON-RPC on conn.
    func NewServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec {
    	return &serverCodec{
    		dec:     json.NewDecoder(conn),
    		enc:     json.NewEncoder(conn),
    		c:       conn,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. src/net/rpc/jsonrpc/all_test.go

    	err := client.Call("Arith.Add", args, reply)
    	if err == nil {
    		t.Error("expected error")
    	}
    }
    
    func TestServerErrorHasNullResult(t *testing.T) {
    	var out strings.Builder
    	sc := NewServerCodec(struct {
    		io.Reader
    		io.Writer
    		io.Closer
    	}{
    		Reader: strings.NewReader(`{"method": "Arith.Add", "id": "123", "params": []}`),
    		Writer: &out,
    		Closer: io.NopCloser(nil),
    	})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Sep 07 01:09:53 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go

    		{"Server", Type, 0},
    		{"ServerCodec", Type, 0},
    		{"ServerError", Type, 0},
    	},
    	"net/rpc/jsonrpc": {
    		{"Dial", Func, 0},
    		{"NewClient", Func, 0},
    		{"NewClientCodec", Func, 0},
    		{"NewServerCodec", Func, 0},
    		{"ServeConn", Func, 0},
    	},
    	"net/smtp": {
    		{"(*Client).Auth", Method, 0},
    		{"(*Client).Close", Method, 2},
    		{"(*Client).Data", Method, 0},
    		{"(*Client).Extension", Method, 0},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 534.2K bytes
    - Viewed (0)
  4. api/go1.txt

    pkg net/rpc/jsonrpc, func NewClient(io.ReadWriteCloser) *rpc.Client
    pkg net/rpc/jsonrpc, func NewClientCodec(io.ReadWriteCloser) rpc.ClientCodec
    pkg net/rpc/jsonrpc, func NewServerCodec(io.ReadWriteCloser) rpc.ServerCodec
    pkg net/rpc/jsonrpc, func ServeConn(io.ReadWriteCloser)
    pkg net/smtp, func CRAMMD5Auth(string, string) Auth
    pkg net/smtp, func Dial(string) (*Client, error)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top