aboutsummaryrefslogtreecommitdiff
path: root/format/sideband64k/encoder_buffered_flush_behavior_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'format/sideband64k/encoder_buffered_flush_behavior_test.go')
-rw-r--r--format/sideband64k/encoder_buffered_flush_behavior_test.go21
1 files changed, 16 insertions, 5 deletions
diff --git a/format/sideband64k/encoder_buffered_flush_behavior_test.go b/format/sideband64k/encoder_buffered_flush_behavior_test.go
index f804f231..5c8b358f 100644
--- a/format/sideband64k/encoder_buffered_flush_behavior_test.go
+++ b/format/sideband64k/encoder_buffered_flush_behavior_test.go
@@ -16,18 +16,25 @@ func TestEncoderBufferedFlushBehavior(t *testing.T) {
bw := bufio.NewWriter(&out)
enc := sideband64k.NewEncoder(bw)
- if err := enc.WriteData([]byte("hello")); err != nil {
+ err := enc.WriteData([]byte("hello"))
+ if err != nil {
t.Fatalf("WriteData: %v", err)
}
- if err := enc.WriteFlush(); err != nil {
+
+ err = enc.WriteFlush()
+ if err != nil {
t.Fatalf("WriteFlush: %v", err)
}
+
if out.Len() != 0 {
t.Fatalf("WriteFlush should not flush I/O, got %q", out.String())
}
- if err := enc.FlushIO(); err != nil {
+
+ err = enc.FlushIO()
+ if err != nil {
t.Fatalf("FlushIO: %v", err)
}
+
if got, want := out.String(), "000a\x01hello0000"; got != want {
t.Fatalf("got %q, want %q", got, want)
}
@@ -36,12 +43,16 @@ func TestEncoderBufferedFlushBehavior(t *testing.T) {
bw = bufio.NewWriter(&out)
enc = sideband64k.NewEncoder(bw)
- if err := enc.WriteData([]byte("yo")); err != nil {
+ err = enc.WriteData([]byte("yo"))
+ if err != nil {
t.Fatalf("WriteData: %v", err)
}
- if err := enc.WriteFlushAndFlushIO(); err != nil {
+
+ err = enc.WriteFlushAndFlushIO()
+ if err != nil {
t.Fatalf("WriteFlushAndFlushIO: %v", err)
}
+
if got, want := out.String(), "0007\x01yo0000"; got != want {
t.Fatalf("got %q, want %q", got, want)
}