stream_test.go 1.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package jsoniter
  2. import (
  3. "github.com/stretchr/testify/require"
  4. "testing"
  5. )
  6. func Test_writeByte_should_grow_buffer(t *testing.T) {
  7. should := require.New(t)
  8. stream := NewStream(ConfigDefault, nil, 1)
  9. stream.writeByte('1')
  10. should.Equal("1", string(stream.Buffer()))
  11. should.Equal(1, len(stream.buf))
  12. stream.writeByte('2')
  13. should.Equal("12", string(stream.Buffer()))
  14. should.Equal(2, len(stream.buf))
  15. stream.writeThreeBytes('3', '4', '5')
  16. should.Equal("12345", string(stream.Buffer()))
  17. }
  18. func Test_writeBytes_should_grow_buffer(t *testing.T) {
  19. should := require.New(t)
  20. stream := NewStream(ConfigDefault, nil, 1)
  21. stream.Write([]byte{'1', '2'})
  22. should.Equal("12", string(stream.Buffer()))
  23. should.Equal(2, len(stream.buf))
  24. stream.Write([]byte{'3', '4', '5', '6', '7'})
  25. should.Equal("1234567", string(stream.Buffer()))
  26. should.Equal(7, len(stream.buf))
  27. }
  28. func Test_writeIndention_should_grow_buffer(t *testing.T) {
  29. should := require.New(t)
  30. stream := NewStream(Config{IndentionStep: 2}.Froze(), nil, 1)
  31. stream.WriteVal([]int{1, 2, 3})
  32. should.Equal("[\n 1,\n 2,\n 3\n]", string(stream.Buffer()))
  33. }
  34. func Test_writeRaw_should_grow_buffer(t *testing.T) {
  35. should := require.New(t)
  36. stream := NewStream(ConfigDefault, nil, 1)
  37. stream.WriteRaw("123")
  38. should.Nil(stream.Error)
  39. should.Equal("123", string(stream.Buffer()))
  40. }
  41. func Test_writeString_should_grow_buffer(t *testing.T) {
  42. should := require.New(t)
  43. stream := NewStream(ConfigDefault, nil, 0)
  44. stream.WriteString("123")
  45. should.Nil(stream.Error)
  46. should.Equal(`"123"`, string(stream.Buffer()))
  47. }
  48. type NopWriter struct {
  49. bufferSize int
  50. }
  51. func (w *NopWriter) Write(p []byte) (n int, err error) {
  52. w.bufferSize = cap(p)
  53. return len(p), nil
  54. }
  55. func Test_flush_buffer_should_stop_grow_buffer(t *testing.T) {
  56. writer := new(NopWriter)
  57. NewEncoder(writer).Encode(make([]int, 10000000))
  58. should := require.New(t)
  59. should.Equal(8, writer.bufferSize)
  60. }