NewFrontend and NewBackend cannot fail

backend.go

@@ -33,8 +33,8 @@ type Backend struct {
 }
 
 // NewBackend creates a new Backend.
-func NewBackend(cr ChunkReader, w io.Writer) (*Backend, error) {
+func NewBackend(cr ChunkReader, w io.Writer) *Backend {
-	return &Backend{cr: cr, w: w}, nil
+	return &Backend{cr: cr, w: w}
 }
 
 // Send sends a message to the frontend.

backend_test.go

@@ -12,10 +12,7 @@ func TestBackendReceiveInterrupted(t *testing.T) {
 	server := &interruptReader{}
 	server.push([]byte{'Q', 0, 0, 0, 6})
 
-	backend, err := pgproto3.NewBackend(pgproto3.NewChunkReader(server), nil)
+	backend := pgproto3.NewBackend(pgproto3.NewChunkReader(server), nil)
-	if err != nil {
-		t.Fatal(err)
-	}
 
 	msg, err := backend.Receive()
 	if err == nil {

frontend.go

@@ -42,8 +42,8 @@ type Frontend struct {
 }
 
 // NewFrontend creates a new Frontend.
-func NewFrontend(cr ChunkReader, w io.Writer) (*Frontend, error) {
+func NewFrontend(cr ChunkReader, w io.Writer) *Frontend {
-	return &Frontend{cr: cr, w: w}, nil
+	return &Frontend{cr: cr, w: w}
 }
 
 // Send sends a message to the backend.

frontend_test.go

@@ -36,10 +36,7 @@ func TestFrontendReceiveInterrupted(t *testing.T) {
 	server := &interruptReader{}
 	server.push([]byte{'Z', 0, 0, 0, 5})
 
-	frontend, err := pgproto3.NewFrontend(pgproto3.NewChunkReader(server), nil)
+	frontend := pgproto3.NewFrontend(pgproto3.NewChunkReader(server), nil)
-	if err != nil {
-		t.Fatal(err)
-	}
 
 	msg, err := frontend.Receive()
 	if err == nil {