@@ -81,7 +81,7 @@ func (s *Stream) RemoveReceiver(r *Receiver) {
8181func (s * Stream ) listen () {
8282 for e := range s .incoming {
8383 switch e .(type ) {
84- case * mastodon.UpdateEvent , * mastodon.NotificationEvent , * mastodon.DeleteEvent , * mastodon.ErrorEvent :
84+ case * mastodon.UpdateEvent , * mastodon.ConversationEvent , * mastodon. NotificationEvent , * mastodon.DeleteEvent , * mastodon.ErrorEvent :
8585 for _ , r := range s .receivers {
8686 go func (rec * Receiver , e mastodon.Event ) {
8787 rec .mux .Lock ()
@@ -133,17 +133,17 @@ func (ac *AccountClient) NewGenericStream(st StreamType, data string) (rec *Rece
133133 var ch chan mastodon.Event
134134 switch st {
135135 case HomeStream :
136- ch , err = ac .Client . StreamingUser (context .Background ())
136+ ch , err = ac .WSClient . StreamingWSUser (context .Background ())
137137 case LocalStream :
138- ch , err = ac .Client . StreamingPublic (context .Background (), true )
138+ ch , err = ac .WSClient . StreamingWSPublic (context .Background (), true )
139139 case FederatedStream :
140- ch , err = ac .Client . StreamingPublic (context .Background (), false )
140+ ch , err = ac .WSClient . StreamingWSPublic (context .Background (), false )
141141 case DirectStream :
142- ch , err = ac .Client . StreamingDirect (context .Background ())
142+ ch , err = ac .WSClient . StreamingWSDirect (context .Background ())
143143 case TagStream :
144- ch , err = ac .Client . StreamingHashtag (context .Background (), data , false )
144+ ch , err = ac .WSClient . StreamingWSHashtag (context .Background (), data , false )
145145 case ListStream :
146- ch , err = ac .Client . StreamingList (context .Background (), mastodon .ID (data ))
146+ ch , err = ac .WSClient . StreamingWSList (context .Background (), mastodon .ID (data ))
147147 default :
148148 panic ("invalid StreamType" )
149149 }
0 commit comments