Add ServerOperation and queue.

pkg/analysis_server/test/operation/operation_queue_test.dart

+// Copyright (c) 2014, 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.
+
+library test.operation.queue;
+
+import 'package:analysis_server/src/operation/operation.dart';
+import 'package:analysis_server/src/operation/operation_queue.dart';
+import 'package:typed_mock/typed_mock.dart';
+import 'package:unittest/unittest.dart';
+
+main() {
+  groupSep = ' | ';
+
+  group('ServerOperationQueue', () {
+    ServerOperationQueue queue;
+
+    setUp(() {
+      queue = new ServerOperationQueue();
+    });
+
+    group('add', () {
+      group('MergeableOperation', () {
+        test('false', () {
+          var operationA = mockMergeableOperation(ServerOperationPriority.SEARCH);
+          var operationB = mockMergeableOperation(ServerOperationPriority.SEARCH);
+          when(operationA.mergeWith(operationB)).thenReturn(false);
+          queue.add(operationA);
+          queue.add(operationB);
+          expect(queue.take(), operationA);
+          expect(queue.take(), operationB);
+          expect(queue.take(), null);

[Brian Wilkerson, 2014/06/02 14:32:18]

Should this (and line 42) be "isNull"?

[scheglov, 2014/06/02 17:56:59]

As I see it now, we actually don't need mergeable operations.

+        });
+
+        test('true', () {
+          var operationA = mockMergeableOperation(ServerOperationPriority.SEARCH);
+          var operationB = mockMergeableOperation(ServerOperationPriority.SEARCH);
+          when(operationA.mergeWith(operationB)).thenReturn(true);
+          queue.add(operationA);
+          queue.add(operationB);
+          expect(queue.take(), operationA);
+          expect(queue.take(), null);
+        });
+      });
+
+      test('false', () {

[Brian Wilkerson, 2014/06/02 14:32:18]

This test is duplicated on line 58.

[scheglov, 2014/06/02 17:56:59]

Removed.

+        var operation = mockOperation(ServerOperationPriority.SEARCH);
+        queue.add(operation);
+        expect(queue.isEmpty, isFalse);
+      });
+    });
+
+    group('isEmpty', () {
+      test('true', () {
+        expect(queue.isEmpty, isTrue);
+      });
+
+      test('false', () {
+        var operation = mockOperation(ServerOperationPriority.SEARCH);
+        queue.add(operation);
+        expect(queue.isEmpty, isFalse);
+      });
+    });
+
+    group('take', () {
+      test('empty', () {
+        expect(queue.take(), isNull);
+      });
+
+      test('use priorities', () {
+        var operationA = mockOperation(ServerOperationPriority.SEARCH);
+        var operationB = mockOperation(ServerOperationPriority.REFACTORING);
+        var operationC = mockOperation(ServerOperationPriority.ANALYSIS);
+        queue.add(operationA);
+        queue.add(operationB);
+        queue.add(operationC);
+        expect(queue.take(), operationC);
+        expect(queue.take(), operationA);
+        expect(queue.take(), operationB);
+        expect(queue.take(), isNull);
+      });
+    });
+  });
+}
+
+
+/**
+ *  Return a [ServerOperation] mock with the given priority.
+ */
+ServerOperation mockOperation(ServerOperationPriority priority) {
+  ServerOperation operation = new ServerOperationMock();
+  when(operation.priority).thenReturn(priority);
+  return operation;
+}
+
+
+/**
+ *  Return a [MergeableOperation] mock with the given priority.
+ */
+MergeableOperation mockMergeableOperation(ServerOperationPriority priority) {
+  MergeableOperation operation = new MergeableOperationMock();
+  when(operation.priority).thenReturn(priority);
+  return operation;
+}
+
+
+class ServerOperationMock extends TypedMock implements ServerOperation {
+  noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation);
+}
+
+
+class MergeableOperationMock extends TypedMock implements MergeableOperation {
+  noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation);
+}