blob: 4c511eb6da8c92727d8013c46a79ba4e44a1eec7 [file] [log] [blame]
// Copyright 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include <memory>
#include "base/macros.h"
#include "base/memory/ref_counted.h"
namespace heap_profiling {
// A stream receiver is a sink for unparsed bytes. See also LogReceiver.
class StreamReceiver : public base::RefCountedThreadSafe<StreamReceiver> {
StreamReceiver() {}
// Returns true on success, false on unrecoverable error. The implementation
// should be able to handle calls after an error has been reported (some
// cross-thread calls may have been dispatched before the flag propagates).
virtual bool OnStreamData(std::unique_ptr<char[]> data, size_t sz) = 0;
// Indicates the connection has been closed.
virtual void OnStreamComplete() = 0;
friend class base::RefCountedThreadSafe<StreamReceiver>;
virtual ~StreamReceiver() {}
} // namespace heap_profiling