mirror of
https://github.com/telegramdesktop/tdesktop
synced 2025-09-03 16:05:57 +00:00
Subscribe to channel updates in voice chat.
This commit is contained in:
@@ -10,6 +10,7 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
|
|||||||
#include "calls/calls_group_common.h"
|
#include "calls/calls_group_common.h"
|
||||||
#include "main/main_session.h"
|
#include "main/main_session.h"
|
||||||
#include "api/api_send_progress.h"
|
#include "api/api_send_progress.h"
|
||||||
|
#include "api/api_updates.h"
|
||||||
#include "apiwrap.h"
|
#include "apiwrap.h"
|
||||||
#include "lang/lang_keys.h"
|
#include "lang/lang_keys.h"
|
||||||
#include "lang/lang_hardcoded.h"
|
#include "lang/lang_hardcoded.h"
|
||||||
@@ -387,8 +388,11 @@ void GroupCall::join(const MTPInputGroupCall &inputCall) {
|
|||||||
|
|
||||||
addParticipantsToInstance();
|
addParticipantsToInstance();
|
||||||
|
|
||||||
|
_peer->session().updates().addActiveChat(
|
||||||
|
_peerStream.events_starting_with_copy(_peer));
|
||||||
SubscribeToMigration(_peer, _lifetime, [=](not_null<ChannelData*> group) {
|
SubscribeToMigration(_peer, _lifetime, [=](not_null<ChannelData*> group) {
|
||||||
_peer = group;
|
_peer = group;
|
||||||
|
_peerStream.fire_copy(group);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -280,6 +280,7 @@ private:
|
|||||||
|
|
||||||
const not_null<Delegate*> _delegate;
|
const not_null<Delegate*> _delegate;
|
||||||
not_null<PeerData*> _peer; // Can change in legacy group migration.
|
not_null<PeerData*> _peer; // Can change in legacy group migration.
|
||||||
|
rpl::event_stream<PeerData*> _peerStream;
|
||||||
not_null<History*> _history; // Can change in legacy group migration.
|
not_null<History*> _history; // Can change in legacy group migration.
|
||||||
MTP::Sender _api;
|
MTP::Sender _api;
|
||||||
rpl::variable<State> _state = State::Creating;
|
rpl::variable<State> _state = State::Creating;
|
||||||
|
Reference in New Issue
Block a user