plugins/jobs/oooold/broker/beanstalk/tube_test.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

package beanstalk

import (
	"github.com/stretchr/testify/assert"
	"testing"
)

func TestTube_CantServe(t *testing.T) {
	var gctx interface{}
	tube := &tube{
		lsn: func(event int, ctx interface{}) {
			gctx = ctx
		},
	}

	tube.serve(&Config{Addr: "broken"})
	assert.Error(t, gctx.(error))
}