fix

lib/fed/decoder.go

@@ -39,6 +39,9 @@ func (T *Decoder) Reset(r io.Reader) {
 }
 
 func (T *Decoder) refill() error {
+	if T.bufferWrite >= len(T.buffer) {
+		return nil
+	}
 	n, err := T.reader.Read(T.buffer[T.bufferWrite:])
 	T.bufferWrite += n
 	return err

lib/fed/encoder.go

@@ -60,6 +60,9 @@ func (T *Encoder) ReadFrom(r *Decoder) (int, error) {
 }
 
 func (T *Encoder) Flush() error {
+	if T.bufferPos == 0 {
+		return nil
+	}
 	_, err := T.writer.Write(T.buffer[:T.bufferPos])
 	T.bufferPos = 0
 	return err

lib/gsql/query_test.go

@@ -54,7 +54,10 @@ func TestQuery(t *testing.T) {
 
 	var b flip.Bank
 	b.Queue(func() error {
-		return gsql.ExtendedQuery(inward, &res, "SELECT usename, passwd FROM pg_shadow WHERE usename=$1", "postgres")
+		if err := gsql.ExtendedQuery(inward, &res, "SELECT usename, passwd FROM pg_shadow WHERE usename=$1", "postgres"); err != nil {
+			return err
+		}
+		return nil
 	})
 
 	b.Queue(func() error {
@@ -69,7 +72,10 @@ func TestQuery(t *testing.T) {
 		if serverErr != nil {
 			return serverErr
 		}
-		return outward.Close()
+		if err := outward.Close(); err != nil {
+			return err
+		}
+		return nil
 	})
 
 	if err = b.Wait(); err != nil {