Merge pull request #19 from ericxtang/master
update example code to the new version
This commit is contained in:
commit
4b82a8ce74
@ -53,8 +53,8 @@ func main() {
|
|||||||
ch := channels[conn.URL.Path]
|
ch := channels[conn.URL.Path]
|
||||||
if ch == nil {
|
if ch == nil {
|
||||||
ch = &Channel{}
|
ch = &Channel{}
|
||||||
ch.que = pubsub.NewQueue(streams)
|
ch.que = pubsub.NewQueue()
|
||||||
ch.que.SetMaxDuration(time.Minute)
|
ch.que.WriteHeader(streams)
|
||||||
channels[conn.URL.Path] = ch
|
channels[conn.URL.Path] = ch
|
||||||
} else {
|
} else {
|
||||||
ch = nil
|
ch = nil
|
||||||
|
Loading…
x
Reference in New Issue
Block a user