diff options
Diffstat (limited to 'internal/processing/stream')
| -rw-r--r-- | internal/processing/stream/stream.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/internal/processing/stream/stream.go b/internal/processing/stream/stream.go index bd49a330c..972173c7a 100644 --- a/internal/processing/stream/stream.go +++ b/internal/processing/stream/stream.go @@ -28,13 +28,14 @@ import ( type Processor struct { state *state.State oauthServer oauth.Server - streamMap sync.Map + streamMap *sync.Map } func New(state *state.State, oauthServer oauth.Server) Processor { return Processor{ state: state, oauthServer: oauthServer, + streamMap: &sync.Map{}, } } |