tests/standalone/io/list_input_stream_test.dart

// Copyright (c) 2012, 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:io";
import "dart:isolate";

void testEmptyListInputStream() {
  ListInputStream stream = new ListInputStream();
  stream.write([]);
  stream.markEndOfStream();
  ReceivePort donePort = new ReceivePort();

  void onData() {
    throw "No data expected";
  }

  void onClosed() {
    donePort.toSendPort().send(null);
  }

  stream.onData = onData;
  stream.onClosed = onClosed;

  donePort.receive((x,y) => donePort.close());
}

void testEmptyDynamicListInputStream() {
  ListInputStream stream = new ListInputStream();
  ReceivePort donePort = new ReceivePort();

  void onData() {
    throw "No data expected";
  }

  void onClosed() {
    donePort.toSendPort().send(null);
  }

  stream.onData = onData;
  stream.onClosed = onClosed;
  stream.markEndOfStream();

  donePort.receive((x,y) => donePort.close());
}

void testListInputStream1() {
  List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
  ListInputStream stream = new ListInputStream();
  stream.write(data);
  stream.markEndOfStream();
  int count = 0;
  ReceivePort donePort = new ReceivePort();

  void onData() {
    List<int> x = stream.read(1);
    Expect.equals(1, x.length);
    Expect.equals(data[count++], x[0]);
  }

  void onClosed() {
    Expect.equals(data.length, count);
    donePort.toSendPort().send(count);
  }

  stream.onData = onData;
  stream.onClosed = onClosed;

  donePort.receive((x,y) => donePort.close());
}

void testListInputStream2() {
  List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
  ListInputStream stream = new ListInputStream();
  stream.write(data);
  stream.markEndOfStream();
  int count = 0;
  ReceivePort donePort = new ReceivePort();

  void onData() {
    List<int> x = new List<int>.fixedLength(2);
    var bytesRead = stream.readInto(x);
    Expect.equals(2, bytesRead);
    Expect.equals(data[count++], x[0]);
    Expect.equals(data[count++], x[1]);
  }

  void onClosed() {
    Expect.equals(data.length, count);
    donePort.toSendPort().send(count);
  }

  stream.onData = onData;
  stream.onClosed = onClosed;

  donePort.receive((x,y) => donePort.close());
}

void testListInputStreamPipe1() {
  List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
  ListInputStream input = new ListInputStream();
  input.write(data);
  input.markEndOfStream();
  ListOutputStream output = new ListOutputStream();
  ReceivePort donePort = new ReceivePort();

  void onClosed() {
    var contents = output.read();
    Expect.equals(data.length, contents.length);
    donePort.toSendPort().send(null);
  }

  input.onClosed = onClosed;
  input.pipe(output);

  donePort.receive((x,y) => donePort.close());
}

void testListInputStreamPipe2() {
  List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
  ListOutputStream output = new ListOutputStream();
  ReceivePort donePort = new ReceivePort();
  int count = 0;

  void onClosed() {
    if (count < 10) {
      ListInputStream input = new ListInputStream();
      input.write(data);
      input.markEndOfStream();
      input.onClosed = onClosed;
      if (count < 9) {
        input.pipe(output, close: false);
      } else {
        input.pipe(output);
      }
      count++;
    } else {
      var contents = output.read();
      Expect.equals(data.length * 10, contents.length);
      donePort.toSendPort().send(null);
    }
  }

  ListInputStream input = new ListInputStream();
  input.write(data);
  input.markEndOfStream();
  input.onClosed = onClosed;
  input.pipe(output, close: false);
  count++;

  donePort.receive((x,y) => donePort.close());
}

void testListInputClose1() {
  List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
  ListInputStream stream = new ListInputStream();
  stream.write(data);
  stream.markEndOfStream();
  ReceivePort donePort = new ReceivePort();

  void onData() {
    throw "No data expected";
  }

  void onClosed() {
    donePort.toSendPort().send(null);
  }

  stream.onData = onData;
  stream.onClosed = onClosed;
  stream.close();

  donePort.receive((x,y) => donePort.close());
}

void testListInputClose2() {
  List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
  ListInputStream stream = new ListInputStream();
  stream.write(data);
  stream.markEndOfStream();
  ReceivePort donePort = new ReceivePort();
  int count = 0;

  void onData() {
    count += stream.read(2).length;
    stream.close();
  }

  void onClosed() {
    Expect.equals(2, count);
    donePort.toSendPort().send(count);
  }

  stream.onData = onData;
  stream.onClosed = onClosed;

  donePort.receive((x,y) => donePort.close());
}

void testDynamicListInputStream() {
  List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
  ListInputStream stream = new ListInputStream();
  int count = 0;
  ReceivePort donePort = new ReceivePort();

  void onData() {
    List<int> x = stream.read(1);
    Expect.equals(1, x.length);
    x = stream.read();
    Expect.equals(9, x.length);
    count++;
    if (count < 10) {
      stream.write(data);
    } else {
      stream.markEndOfStream();
    }
  }

  void onClosed() {
    Expect.equals(data.length, count);
    donePort.toSendPort().send(count);
  }

  stream.write(data);
  stream.onData = onData;
  stream.onClosed = onClosed;

  donePort.receive((x,y) => donePort.close());
}

void testDynamicListInputClose1() {
  List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
  ListInputStream stream = new ListInputStream();
  ReceivePort donePort = new ReceivePort();

  void onData() {
    throw "No data expected";
  }

  void onClosed() {
    donePort.toSendPort().send(null);
  }

  stream.write(data);
  stream.onData = onData;
  stream.onClosed = onClosed;
  stream.close();
  Expect.throws(() => stream.write(data), (e) => e is StreamException);

  donePort.receive((x,y) => donePort.close());
}

void testDynamicListInputClose2() {
  List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
  ListInputStream stream = new ListInputStream();
  ReceivePort donePort = new ReceivePort();
  int count = 0;

  void onData() {
    count += stream.read(15).length;
    stream.close();
    Expect.throws(() => stream.write(data), (e) => e is StreamException);
  }

  void onClosed() {
    Expect.equals(15, count);
    donePort.toSendPort().send(null);
  }

  stream.write(data);
  stream.write(data);
  stream.write(data);
  stream.onData = onData;
  stream.onClosed = onClosed;

  donePort.receive((x,y) => donePort.close());
}

main() {
  testEmptyListInputStream();
  testEmptyDynamicListInputStream();
  testListInputStream1();
  testListInputStream2();
  testListInputStreamPipe1();
  testListInputStreamPipe2();
  testListInputClose1();
  testListInputClose2();
  testDynamicListInputStream();
  testDynamicListInputClose1();
  testDynamicListInputClose2();
}