1 В избранное 0 Ответвления 0

OSCHINA-MIRROR/shxsun-gosuv

Клонировать/Скачать
broadcast_test.go 1.2 КБ
Копировать Редактировать Web IDE Исходные данные Просмотреть построчно История
codeskyblue Отправлено 06.09.2016 09:24 534f7d8
package main
import (
"testing"
. "github.com/smartystreets/goconvey/convey"
)
// func TestBroadcast(t *testing.T) {
// bs := NewBroadcastString()
// bs.WriteMessage("hello")
// time.Sleep(10 * time.Millisecond)
// c1 := bs.AddListener(nil)
// go func() {
// bs.WriteMessage("world")
// }()
// message := <-c1
// if message != "world" {
// t.Fatalf("expect message world, but got %s", message)
// }
// c2 := bs.AddListener(nil)
// go func() {
// bs.WriteMessage("tab")
// }()
// // test write multi
// wg := sync.WaitGroup{}
// wg.Add(2)
// go func() {
// message = <-c2
// if message != "tab" {
// t.Errorf("expect tab, but got %s", message)
// }
// wg.Done()
// }()
// go func() {
// message = <-c1
// if message != "tab" {
// t.Errorf("expect tab, but got %s", message)
// }
// wg.Done()
// }()
// wg.Wait()
// }
func TestRingBuffer(t *testing.T) {
Convey("Write some string to ring buffer", t, func() {
// buf := rbuf.NewFixedSizeRingBuf(5)
// buf.Write([]byte("abcde"))
// So(string(buf.Bytes()), ShouldEqual, "abcde")
// buf.Advance(2)
// buf.Write([]byte("fg"))
// So(string(buf.Bytes()), ShouldEqual, "cdefg")
})
}

Опубликовать ( 0 )

Вы можете оставить комментарий после Вход в систему

1
https://api.gitlife.ru/oschina-mirror/shxsun-gosuv.git
git@api.gitlife.ru:oschina-mirror/shxsun-gosuv.git
oschina-mirror
shxsun-gosuv
shxsun-gosuv
master