bug fixing

This commit is contained in:
Michele Caini 2016-07-04 08:56:34 +02:00
parent 09acc1accf
commit 015e2a8bb2

View File

@ -28,7 +28,7 @@ class Stream: public Handle<T> {
if(nread == UV_EOF) { if(nread == UV_EOF) {
ref.publish(EndEvent{}); ref.publish(EndEvent{});
delete buf->base; delete[] buf->base;
} else if(nread > 0) { } else if(nread > 0) {
std::unique_ptr<char[]> data{buf->base}; std::unique_ptr<char[]> data{buf->base};
DataEvent event; DataEvent event;
@ -36,7 +36,7 @@ class Stream: public Handle<T> {
ref.publish(std::move(event)); ref.publish(std::move(event));
} else { } else {
ref.publish(ErrorEvent(nread)); ref.publish(ErrorEvent(nread));
delete buf->base; delete[] buf->base;
} }
buf->base = nullptr; buf->base = nullptr;