Skip to content

Commit

Permalink
ensure writes succeed
Browse files Browse the repository at this point in the history
Signed-off-by: razzle <harry@razzle.cloud>
  • Loading branch information
Noxsios committed May 23, 2024
1 parent 6aa9329 commit d38e690
Showing 1 changed file with 9 additions and 3 deletions.
12 changes: 9 additions & 3 deletions src/pkg/message/pausable_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,19 +15,25 @@ func TestPausableWriter(t *testing.T) {

pw := NewPausableWriter(&buf)

pw.Write([]byte("foo"))
n, err := pw.Write([]byte("foo"))
require.NoError(t, err)
require.Equal(t, 3, n)

require.Equal(t, "foo", buf.String())

pw.Pause()

pw.Write([]byte("bar"))
n, err = pw.Write([]byte("bar"))
require.NoError(t, err)
require.Equal(t, 3, n)

require.Equal(t, "foo", buf.String())

pw.Resume()

pw.Write([]byte("baz"))
n, err = pw.Write([]byte("baz"))
require.NoError(t, err)
require.Equal(t, 3, n)

require.Equal(t, "foobaz", buf.String())
}

0 comments on commit d38e690

Please sign in to comment.