Skip to content

Commit 524b72b

Browse files
afrindfacebook-github-bot
authored andcommitted
Run tests for all versions
Differential Revision: D74500562
1 parent 4f8e29d commit 524b72b

File tree

2 files changed

+113
-79
lines changed

2 files changed

+113
-79
lines changed

moxygen/MoQSession.cpp

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -320,7 +320,8 @@ StreamPublisherImpl::StreamPublisherImpl(
320320
SubgroupIDFormat format,
321321
bool includeExtensions)
322322
: StreamPublisherImpl(publisher) {
323-
streamType_ = StreamType::SUBGROUP_HEADER;
323+
streamType_ =
324+
getSubgroupStreamType(publisher->getVersion(), format, includeExtensions);
324325
header_.trackIdentifier = alias;
325326
setWriteHandle(writeHandle);
326327
setGroupAndSubgroup(groupID, subgroupID);
@@ -397,7 +398,7 @@ StreamPublisherImpl::writeCurrentObject(
397398

398399
folly::Expected<folly::Unit, MoQPublishError>
399400
StreamPublisherImpl::writeToStream(bool finStream) {
400-
if (streamType_ == StreamType::SUBGROUP_HEADER &&
401+
if (streamType_ != StreamType::FETCH_HEADER &&
401402
!publisher_->canBufferBytes(writeBuf_.chainLength())) {
402403
publisher_->onTooManyBytesBuffered();
403404
return folly::makeUnexpected(

0 commit comments

Comments
 (0)