code.ivysaur.me/libnmdc
1
0
Fork 0
Code Issues 2 Pull Requests Releases 17 Activity

libnmdc: reinstate backward-compatibility re new sync api

Browse Source
This commit is contained in:
mappu 2016-04-03 18:59:11 +12:00
parent 019f67a7de
commit 73f6d66cbd
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/libnmdc/libnmdc.go
View File

@ -87,7 +87,6 @@ type HubConnectionOptions struct {
// Returning messages in async mode // Returning messages in async mode
NumEventsToBuffer uint NumEventsToBuffer uint
OnEvent chan HubEvent
// Returning messages in sync mode // Returning messages in sync mode
OnEventSync func(HubEvent) OnEventSync func(HubEvent)
@ -104,6 +103,7 @@ type HubConnection struct {
// Streamed events // Streamed events
processEvent func(HubEvent) processEvent func(HubEvent)
OnEvent chan HubEvent
// Private state // Private state
conn net.Conn // this is an interface conn net.Conn // this is an interface
@ -428,14 +428,11 @@ func (this *HubConnectionOptions) Connect() *HubConnection {
if this.NumEventsToBuffer < 1 { if this.NumEventsToBuffer < 1 {
this.NumEventsToBuffer = 1 this.NumEventsToBuffer = 1
} }
if this.OnEvent == nil {
this.OnEvent = make(chan HubEvent, this.NumEventsToBuffer)
}
hc := this.prepareConnection() hc := this.prepareConnection()
hc.OnEvent = make(chan HubEvent, this.NumEventsToBuffer)
hc.processEvent = func(ev HubEvent) { hc.processEvent = func(ev HubEvent) {
this.OnEvent <- ev hc.OnEvent <- ev
} }
go hc.worker() go hc.worker()