summaryrefslogtreecommitdiff
path: root/internal/processing/streaming/openstream.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/processing/streaming/openstream.go')
-rw-r--r--internal/processing/streaming/openstream.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/processing/streaming/openstream.go b/internal/processing/streaming/openstream.go
index 706cc0675..c256842a4 100644
--- a/internal/processing/streaming/openstream.go
+++ b/internal/processing/streaming/openstream.go
@@ -30,11 +30,11 @@ import (
"github.com/superseriousbusiness/gotosocial/internal/stream"
)
-func (p *processor) OpenStreamForAccount(ctx context.Context, account *gtsmodel.Account, streamType string) (*stream.Stream, gtserror.WithCode) {
+func (p *processor) OpenStreamForAccount(ctx context.Context, account *gtsmodel.Account, streamTimeline string) (*stream.Stream, gtserror.WithCode) {
l := logrus.WithFields(logrus.Fields{
"func": "OpenStreamForAccount",
"account": account.ID,
- "streamType": streamType,
+ "streamType": streamTimeline,
})
l.Debug("received open stream request")
@@ -46,7 +46,7 @@ func (p *processor) OpenStreamForAccount(ctx context.Context, account *gtsmodel.
thisStream := &stream.Stream{
ID: streamID,
- Type: streamType,
+ Timeline: streamTimeline,
Messages: make(chan *stream.Message, 100),
Hangup: make(chan interface{}, 1),
Connected: true,