INNER CODE UNIT · Go
TestBuffer
boz/kail · buffer_test.go:9
func TestBuffer(t *testing.T) {
source := eventSource{}
{
buffer := newBuffer(source)
events := buffer.process([]byte(""))
assert.Empty(t, events)
events = buffer.process([]byte("foo\n"))
assert.Len(t, events, 1)
assert.Equal(t, "foo", string(events[0].Log()))
}
{
buffer := newBuffer(source)
events := buffer.process([]byte("foo"))
assert.Empty(t, events)