// Copyright (c) 2016, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

import 'dart:convert';
import 'dart:typed_data';

import 'package:typed_data/typed_data.dart';

/// A sink that provides access to the concatenated bytes passed to it.
///
/// See also [ByteConversionSink.withCallback].
class ByteAccumulatorSink extends ByteConversionSinkBase {
  /// The bytes accumulated so far.
  ///
  /// The returned [Uint8List] is viewing a shared buffer, so it should not be
  /// changed and any bytes outside the view should not be accessed.
  Uint8List get bytes => Uint8List.view(_buffer.buffer, 0, _buffer.length);

  final _buffer = Uint8Buffer();

  /// Whether [close] has been called.
  bool get isClosed => _isClosed;
  var _isClosed = false;

  /// Removes all bytes from [bytes].
  ///
  /// This can be used to avoid double-processing data.
  void clear() {
    _buffer.clear();
  }

  void add(List<int> bytes) {
    if (_isClosed) {
      throw StateError("Can't add to a closed sink.");
    }

    _buffer.addAll(bytes);
  }

  void addSlice(List<int> chunk, int start, int end, bool isLast) {
    if (_isClosed) {
      throw StateError("Can't add to a closed sink.");
    }

    _buffer.addAll(chunk, start, end);
    if (isLast) _isClosed = true;
  }

  void close() {
    _isClosed = true;
  }
}