jsonrpc2: add defaultCapacity constant

zchee · zchee · commit 9c738d5eb023 · 2019-08-13T16:04:08.000+09:00
diff --git a/jsonrpc2.go b/jsonrpc2.go
@@ -141,6 +141,8 @@ var defaultHandler = func(ctx context.Context, req *Request) {
 	}
 }
 
+const defaultCapacity = 20
+
 var defaultCanceler = func(context.Context, *Conn, ID) {}
 
 var defaultLogger = zap.NewNop()
@@ -163,6 +165,10 @@ func NewConn(s Stream, options ...Options) *Conn {
 	if conn.Handler == nil {
 		conn.Handler = defaultHandler
 	}
+	// the default capacity is 20
+	if conn.Capacity == 0 {
+		conn.Capacity = defaultCapacity
+	}
 	// the default canceller does nothing
 	if conn.Canceler == nil {
 		conn.Canceler = defaultCanceler

Original file line number	Diff line number	Diff line change
`@@ -141,6 +141,8 @@ var defaultHandler = func(ctx context.Context, req *Request) {`
`141`	`141`	`}`
`142`	`142`	`}`
`143`	`143`
	`144`	`+const defaultCapacity = 20`
	`145`	`+`
`144`	`146`	`var defaultCanceler = func(context.Context, *Conn, ID) {}`
`145`	`147`
`146`	`148`	`var defaultLogger = zap.NewNop()`
`@@ -163,6 +165,10 @@ func NewConn(s Stream, options ...Options) *Conn {`
`163`	`165`	`if conn.Handler == nil {`
`164`	`166`	`conn.Handler = defaultHandler`
`165`	`167`	`}`
	`168`	`+ // the default capacity is 20`
	`169`	`+ if conn.Capacity == 0 {`
	`170`	`+ conn.Capacity = defaultCapacity`
	`171`	`+ }`
`166`	`172`	`// the default canceller does nothing`
`167`	`173`	`if conn.Canceler == nil {`
`168`	`174`	`conn.Canceler = defaultCanceler`