astra/go-mastodon
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

update

Browse source
This commit is contained in:
Rasmus Lindroth 2022-05-01 17:47:45 +02:00
parent be11f5b013
commit b1b367ca33
45 changed files with 24 additions and 1976 deletions
Download patch file Download diff file Expand all files Collapse all files

12
streaming_test.go
View file

@ -23,12 +23,11 @@ event: delete
data: 1234567
:thump
`)
errs := make(chan error, 1)
go func() {
defer close(q)
err := handleReader(q, r)
if err != nil {
t.Fatalf("should not be fail: %v", err)
}
errs <- err
}()
var passUpdate, passNotification, passDelete, passError bool
for e := range q {
@ -60,6 +59,10 @@ data: 1234567
"update %t, notification %t, delete %t, error %t",
passUpdate, passNotification, passDelete, passError)
}
err := <-errs
if err != nil {
t.Fatalf("should not be fail: %v", err)
}
}
func TestStreaming(t *testing.T) {
@ -142,9 +145,6 @@ func TestDoStreaming(t *testing.T) {
go func() {
defer close(q)
c.doStreaming(req, q)
if err != nil {
t.Fatalf("should not be fail: %v", err)
}
}()
var passError bool
for e := range q {