@@ -534,7 +534,7 @@ class Stream::Outbound final : public MemoryRetainer {
534534 // so that it can not go away during the next calls.
535535 BaseObjectPtr<Stream> stream = BaseObjectPtr<Stream>(stream_);
536536 BaseObjectPtr<Session> session =
537- BaseObjectPtr<Session>(&stream_ ->session ());
537+ BaseObjectPtr<Session>(&stream_->session ());
538538
539539 // The status should never be wait here.
540540 DCHECK_NE (status, bob::Status::STATUS_WAIT);
@@ -544,8 +544,7 @@ class Stream::Outbound final : public MemoryRetainer {
544544 // being asynchronous, our stream is blocking waiting for the data,
545545 // but we have an error! oh no! We need to error the stream.
546546 if (last_next_pending_state) {
547- stream->Destroy (
548- QuicError::ForNgtcp2Error (NGTCP2_INTERNAL_ERROR));
547+ stream->Destroy (QuicError::ForNgtcp2Error (NGTCP2_INTERNAL_ERROR));
549548 // We do not need to worry about calling MarkErrored in this case
550549 // since we are immediately destroying the stream which will
551550 // release the outbound buffer anyway.
@@ -1418,8 +1417,7 @@ JS_METHOD_IMPL(DataQueueFeeder::Submit) {
14181417 memcpy (backing->Data (), originalData, nread);
14191418 auto & pending = feeder->pendingPulls_ .front ();
14201419 auto pop = OnScopeLeave ([feeder] {
1421- if (feeder->pendingPulls_ .size () > 0 )
1422- feeder->pendingPulls_ .pop_front ();
1420+ if (feeder->pendingPulls_ .size () > 0 ) feeder->pendingPulls_ .pop_front ();
14231421 });
14241422 DataQueue::Vec vec;
14251423 vec.base = static_cast <uint8_t *>(backing->Data ());
0 commit comments