Initial commit of RR 2.0v2.0.0-alpha1

1 files changed, 0 insertions, 131 deletions

diff --git a/error_buffer_test.go b/error_buffer_test.go
deleted file mode 100644
index c163ea43..00000000
--- a/error_buffer_test.go
+++ /dev/null
@@ -1,131 +0,0 @@
-package roadrunner
-
-import (
-	"github.com/stretchr/testify/assert"
-	"testing"
-)
-
-func TestErrBuffer_Write_Len(t *testing.T) {
-	buf := newErrBuffer()
-	defer func() {
-		err := buf.Close()
-		if err != nil {
-			t.Errorf("error during closing the buffer: error %v", err)
-		}
-	}()
-
-	_, err := buf.Write([]byte("hello"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-	assert.Equal(t, 5, buf.Len())
-	assert.Equal(t, "hello", buf.String())
-}
-
-func TestErrBuffer_Write_Event(t *testing.T) {
-	buf := newErrBuffer()
-	defer func() {
-		err := buf.Close()
-		if err != nil {
-			t.Errorf("error during closing the buffer: error %v", err)
-		}
-	}()
-
-	tr := make(chan interface{})
-	buf.Listen(func(event int, ctx interface{}) {
-		assert.Equal(t, EventStderrOutput, event)
-		assert.Equal(t, []byte("hello\n"), ctx)
-		close(tr)
-	})
-
-	_, err := buf.Write([]byte("hello\n"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-	<-tr
-
-	// messages are read
-	assert.Equal(t, 0, buf.Len())
-}
-
-func TestErrBuffer_Write_Event_Separated(t *testing.T) {
-	buf := newErrBuffer()
-	defer func() {
-		err := buf.Close()
-		if err != nil {
-			t.Errorf("error during closing the buffer: error %v", err)
-		}
-	}()
-
-	tr := make(chan interface{})
-	buf.Listen(func(event int, ctx interface{}) {
-		assert.Equal(t, EventStderrOutput, event)
-		assert.Equal(t, []byte("hello\nending"), ctx)
-		close(tr)
-	})
-
-	_, err := buf.Write([]byte("hel"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-
-	_, err = buf.Write([]byte("lo\n"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-
-	_, err = buf.Write([]byte("ending"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-
-	<-tr
-	assert.Equal(t, 0, buf.Len())
-	assert.Equal(t, "", buf.String())
-}
-
-func TestErrBuffer_Write_Event_Separated_NoListener(t *testing.T) {
-	buf := newErrBuffer()
-	defer func() {
-		err := buf.Close()
-		if err != nil {
-			t.Errorf("error during closing the buffer: error %v", err)
-		}
-	}()
-
-	_, err := buf.Write([]byte("hel"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-
-	_, err = buf.Write([]byte("lo\n"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-
-	_, err = buf.Write([]byte("ending"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-
-	assert.Equal(t, 12, buf.Len())
-	assert.Equal(t, "hello\nending", buf.String())
-}
-
-func TestErrBuffer_Write_Remaining(t *testing.T) {
-	buf := newErrBuffer()
-	defer func() {
-		err := buf.Close()
-		if err != nil {
-			t.Errorf("error during closing the buffer: error %v", err)
-		}
-	}()
-
-	_, err := buf.Write([]byte("hel"))
-	if err != nil {
-		t.Errorf("fail to write: error %v", err)
-	}
-
-	assert.Equal(t, 3, buf.Len())
-	assert.Equal(t, "hel", buf.String())
-}