|
@@ -37,7 +37,8 @@ void StreamServerComponent::cleanup() {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
void StreamServerComponent::read() {
|
|
void StreamServerComponent::read() {
|
|
|
- while ((int len = this->stream_->available()) > 0) {
|
|
|
|
|
|
|
+ int len;
|
|
|
|
|
+ while ((len = this->stream_->available()) > 0) {
|
|
|
char buf[128];
|
|
char buf[128];
|
|
|
size_t read = this->stream_->readBytes(buf, min(len, 128));
|
|
size_t read = this->stream_->readBytes(buf, min(len, 128));
|
|
|
for (auto const& client : this->clients_)
|
|
for (auto const& client : this->clients_)
|