| 98 | end |
| 99 | |
| 100 | def test_reset |
| 101 | @decoder.consume_bytes(@buffer.data.to_s[0, 10]) |
| 102 | @decoder.reset |
| 103 | @decoder.consume_bytes(@buffer.data) |
| 104 | assert_equal([ |
| 105 | [:schema_decoded, @schema, @schema], |
| 106 | [:record_batch_decoded, @record_batch, nil], |
| 107 | [:eos], |
| 108 | ], |
| 109 | @listener.events) |
| 110 | end |
| 111 | |
| 112 | def test_schema |
| 113 | assert_nil(@decoder.schema) |