laurent/arlo-go
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

suppression de logs

Browse Source
This commit is contained in:
Laurent Le Houerou 2020-06-13 15:16:26 +04:00
parent 21aec5f516
commit fa9ec2cfbc
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
event_stream.go
View File

@ -61,8 +61,6 @@ func (e *eventStream) disconnect() {
} }
func (e *eventStream) listen(ctx context.Context) error { func (e *eventStream) listen(ctx context.Context) error {
log.Info("eventStream.listen > start")
err := e.SSEClient.SubscribeChanRaw(e.Events) err := e.SSEClient.SubscribeChanRaw(e.Events)
if err != nil { if err != nil {
return fmt.Errorf("failed to subscribe to seeclient") return fmt.Errorf("failed to subscribe to seeclient")
@ -72,7 +70,6 @@ func (e *eventStream) listen(ctx context.Context) error {
defer func() { defer func() {
e.clearResourceSubscriptions() e.clearResourceSubscriptions()
e.clearTransactionSubscriptions() e.clearTransactionSubscriptions()
log.Info("eventStream.listen > stop")
}() }()
for { for {
@ -90,8 +87,6 @@ func (e *eventStream) listen(ctx context.Context) error {
continue continue
} }
fmt.Printf("DATA : %s\n", event.Data)
var notifyResponse EventStreamResponse var notifyResponse EventStreamResponse
err := json.NewDecoder(bytes.NewBuffer(event.Data)).Decode(&notifyResponse) err := json.NewDecoder(bytes.NewBuffer(event.Data)).Decode(&notifyResponse)
if err != nil { if err != nil {