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