diff --git a/backend.go b/backend.go
index 176a25ba..5741647f 100644
--- a/backend.go
+++ b/backend.go
@@ -33,8 +33,8 @@ type Backend struct {
 }
 
 // NewBackend creates a new Backend.
-func NewBackend(cr ChunkReader, w io.Writer) (*Backend, error) {
-	return &Backend{cr: cr, w: w}, nil
+func NewBackend(cr ChunkReader, w io.Writer) *Backend {
+	return &Backend{cr: cr, w: w}
 }
 
 // Send sends a message to the frontend.
diff --git a/backend_test.go b/backend_test.go
index cd8788b8..43a3f76c 100644
--- a/backend_test.go
+++ b/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)
-	if err != nil {
-		t.Fatal(err)
-	}
+	backend := pgproto3.NewBackend(pgproto3.NewChunkReader(server), nil)
 
 	msg, err := backend.Receive()
 	if err == nil {
diff --git a/frontend.go b/frontend.go
index f6ebaf43..a67b6670 100644
--- a/frontend.go
+++ b/frontend.go
@@ -42,8 +42,8 @@ type Frontend struct {
 }
 
 // NewFrontend creates a new Frontend.
-func NewFrontend(cr ChunkReader, w io.Writer) (*Frontend, error) {
-	return &Frontend{cr: cr, w: w}, nil
+func NewFrontend(cr ChunkReader, w io.Writer) *Frontend {
+	return &Frontend{cr: cr, w: w}
 }
 
 // Send sends a message to the backend.
diff --git a/frontend_test.go b/frontend_test.go
index 1d6a07ae..9b63aa00 100644
--- a/frontend_test.go
+++ b/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)
-	if err != nil {
-		t.Fatal(err)
-	}
+	frontend := pgproto3.NewFrontend(pgproto3.NewChunkReader(server), nil)
 
 	msg, err := frontend.Receive()
 	if err == nil {