const client = TRTC.createClient({
  mode: 'live',
  sdkAppId,
  userId,
  userSig
});


// 以观众角色进房收看
client
  .join({ roomId, role: 'audience' })
  .then(() => {
    console.log('进房成功');
  })
  .catch(error => {
    console.error('进房失败 ' + error);
  });


client.on('stream-added', event => {
  const remoteStream = event.stream;
  console.log('远端流增加: ' + remoteStream.getId());
  //订阅远端流
  client.subscribe(remoteStream);
});
client.on('stream-subscribed', event => {
  const remoteStream = event.stream;
  console.log('远端流订阅成功：' + remoteStream.getId());
  // 播放远端流
  remoteStream.play('remote_stream-' + remoteStream.getId());
});


client.on('stream-subscribed', event => {
    const remoteStream = event.stream;
    console.log('远端流订阅成功：' + remoteStream.getId());
    // 播放远端流
    remoteStream.play('remote_stream-' + remoteStream.getId());
});


client
  .switchRole('anchor')
  .then(() => {
    // 角色切换成功，现在是主播角色
  })
  .catch(error => {
    console.error('角色切换失败 ' + error);
  });


localStream
    .initialize()
    .then(() => {
    console.log('初始化本地流成功');
    })
    .catch(error => {
    console.error('初始化本地流失败 ' + error);
    });


localStream
    .initialize()
    .then(() => {
    console.log('初始化本地流成功');
    localStream.play('local_stream');
    })
    .catch(error => {
    console.error('初始化本地流失败 ' + error);
    });


client
    .publish(localStream)
    .then(() => {
    console.log('本地流发布成功');
    })
    .catch(error => {
    console.error('本地流发布失败 ' + error);
    });


client
  .leave()
  .then(() => {
    // 退房成功
  })
  .catch(error => {
    console.error('退房失败 ' + error);
  });